주키퍼(Zookeeper)와 카프카(Kafka)는 아파치(Apache) 소프트웨어 제단이 스칼라로 개발한 오픈 소스 메세지 브로커예요. ActiveMQ 미들웨어를 사용하다가 고객사에서 카프카를 쓰고 있다고 해서 어쩔 수 없이 만들어 놓은 소스를 뜯어 고쳐야 하는 일이 발생했습니다. 좀 더 일찍 말해주지... ㅠㅠ;

[ 윈도우에서 카프카 설치 및 테스트 ]

 

자~ 여기서 위의 테스트는 잘 될겁니다. 그런데 문제는 C# 카프카 패키지를 사용하면 컨슈머(Consumer)가 제대로 실행되지 않습니다. 아무튼, 아래와 같이 주키퍼를 실행합니다.

zookeeper-server-start.bat ../../config/zookeeper.properties

 

카프카 서버도 실행해주고요~

kafka-server-start.bat ../../config/server.properties

 

토픽을 만들어 줍니다.

kafka-topics.bat --create --topic ngm-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4

 

그런데 이 때 아래와 같은 에러가 발생합니다.

Exception in thread "main" joptsimple.UnrecognizedOptionException: bootstrap-server is not a recognized option

 

토픽을 만들 때 카프카 버전이 2.2 이하라면 bootstrap-server가 아닌 zookeeper를 사용해야 합니다.

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ngm-topic

 

 

개발자에게 후원하기

 

추천, 구독, 홍보 꼭~ 부탁드립니다.

여러분의 후원이 빠른 귀농을 가능하게 해줍니다~ 답답한 도시를 벗어나 귀농하고 싶은 개발자~

감사합니다~

추천0 비추천0