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:58

producer에서 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을 확인해보니 아래와 같은 에러가 발생했다

스크린샷, 2022-12-02 17-28-19

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


해결

image

  • 해당 에러는 그냥 부트 스트랩 서버가 잘못되었을 경우 발생한다고 한다😅

스크린샷, 2022-12-02 17-49-58

  • 아까 9020은 어디서 튀어나왔었지;;; 프로듀서 서버와 같게 수정해주었다
    아무 에러도 뜨지 않는다

References

https://stackoverflow.com/questions/43780665/error-executing-consumer-group-command-failed-due-to-request-group-coordinator