kafka connect에서 kafka broker 설정과 schema registry 설정할 때 조심히 다뤄야 한다.

 

bootstrap.servers=google-test-kafka001.google.io:9092,loki-google-kafka002.google.io:9092,google-test-google.io:9092

key.converter.schema.registry.url=http://google-test-sr001.google.io:8081,http://loki-test-sr002.google.io:8081
value.converter.schema.registry.url=http://google-test-sr001.google.io:8081,http://google-test-sr002.google.io:8081


  kafka broker는 그냥 host와 port만

schema registry는 http를 포함한 host와 port(uri)를 지정한다.

 

알고 나면 매우 당연한데, 막상 설정하다 보면 실수하는 내용이다.

Posted by 김용환 '김용환'

댓글을 달아 주세요