Error Exception in thread "main" joptsimple.UnrecognizedOptionExce…
페이지 정보
본문
주키퍼(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
- 이전글Confluent.Kafka.ConsumeException: 'Broker: Unknown topic or partition' 22.06.08
- 다음글카프카 토픽 삭제하는 방법. (How to delete a topic from kafka.) 22.06.08
댓글목록
등록된 댓글이 없습니다.