使用docker在一台服务器上安装了kafka集群(3节点)
开启生产者与消费者,发现生产者能与入消息,但消费者收不到,另外通过kafka-consumer-groups.sh也查不到消费者的任何信息,在kafka_eagle中能查到logsize在增加
应该怎么解决这个问题?
本人在k8s上部署过N个broker的kafka集群。
1.首先确认下你的kafka版本,一台docker服务器上部署3个节点kafka集群,能提供下你的部署结构吗?还有eafk的截图也看下。
2.然后建议通过docker再拉一个kafka节点执行消费者和生产者测试。
将kafak log.dirs目录给删除,然后重新启动kafka集群,问题解决