카프카 소비자 쿼리

Question

카프카 소비자를 시작하려면 다음 매개 변수를 사용하여 실행해야합니다.

카프카 - 콘솔 consumer.bat --zookeeper 로컬 호스트 : 2181 --topic에 MyTopic

가하는 PARAM로 사육사가 있어야하는 이유 궁금해서 내가 그것을 유사한 작동하지 않습니다 브로커 PARAM를 사용하는 경우 생산자가 어떻게 시작되는지. 소비자는 사육사/클러스터가 아니라 사육사 위치를 알고 있어야합니다.

\ 카프카 - 콘솔 producer.bat --broker --list 로컬 호스트 :. 9092 --topic에 MyTopic이 창에

, 확실하지 않다 방법 유닉스 풍미.

-Chandra

Answer 1

이전 Kafka 소비자를 사용하고 있습니다. 오래된 소비자는 사육사에게 브로커가 데이터를 가져 오기 위해 조정할 것을 요구합니다.

새 소비자는 동물원 매개 변수가 필요하지 않습니다.

.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic MyTopic --new-consumer 

선택적으로, 당신은 주제의 이전 기록을 읽을 --from-beginning 인수를 추가 할 수 있습니다.