isPowerfulBlog
[Kafka] Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups 본문
Data Engineering
[Kafka] Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups
왕밤빵도라에몽 2022. 12. 2. 17:58producer에서 kafka server로 메세지를 보냈을 때 consumer가 메세지를 받아오지 못하는 현상을 해결하는 과정에서 발생한 에러./bin/kafka-consumer-groups.sh
실행 시 에러 발생
-
~/kafka$ ./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
- 카프카에서 토픽 생성하고
~/kafka$ ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
>> test
- 토픽이 정상적으로 생성됨을 확인
# producer
~/kafka$ ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
> publish test message
>
- publish 했는데
# consumer
~/kafka$ ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
>>
- consumer에서 아무 응답이 없다ㅠ.ㅠ
~/kafka$ ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9020 -list
- consumer group을 확인해보니 아래와 같은 에러가 발생했다
Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups java.util.concurrent.ExecutionException: org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups
해결
- 해당 에러는 그냥 부트 스트랩 서버가 잘못되었을 경우 발생한다고 한다😅
- 아까 9020은 어디서 튀어나왔었지;;; 프로듀서 서버와 같게 수정해주었다
아무 에러도 뜨지 않는다
References
'Data Engineering' 카테고리의 다른 글
[Logstash] Forwarding messages from Kafka to Elasticsearch (0) | 2022.12.18 |
---|---|
[Kafka] Consumer not receiving messages (0) | 2022.12.02 |
[Kafka] kafka.common.InconsistentClusterIdException (0) | 2022.11.26 |
[Kafka] Ubuntu 20.04: Kafka 2.13-3.1.0 install (0) | 2022.11.16 |
[ElasticSearch] Job for elasticsearch.service failed because a fatal signal was delivered to the control process. (1) | 2022.11.13 |