kafka connect에서 kafka broker 설정과 schema registry 설정할 때 조심히 다뤄야 한다.
bootstrap.servers=google-test-kafka001.google.io:9092,google-test-kafka002.google.io:9092,google-test-kafka003.google.io:9092
key.converter.schema.registry.url=http://google-test-sr001.google.io:8081,http://google-test-sr002.google.io:8081,http://google-test-sr003.google.io:8081
value.converter.schema.registry.url=http://google-test-sr001.google.io:8081,http://google-test-sr002.google.io:8081,http://google-test-sr003.google.io:8081
kafka broker는 그냥 host와 port만 지정하고
schema registry는 http를 포함한 host와 port(uri)를 지정한다.
알고 나면 매우 당연한데, 막상 설정하다 보면 실수하는 내용이다.
'kafka' 카테고리의 다른 글
카프카의 MirroMaker 간단 소개 (0) | 2019.07.12 |
---|---|
schema-registry HA 이슈 (0) | 2019.04.05 |
kafka connect Creation of database history topic failed, please create the topic manually / TimeoutException 에러 (0) | 2019.03.19 |
stream stream-join 정보와 mjoin (0) | 2019.03.02 |
[펌] kafka burrow api (0) | 2018.11.20 |