fly2749 2023-09-11 22:24 采纳率: 50%
浏览 9
已结题

Kafka单节点集群中的consumer不消费?

Kafka单节点集群中的consumer不消费?只有把broker=0对应的服务端口起来才会消费,这是为什么?

服务配置如下:

kafka-server-start.sh $KAFKA_HOME/config/server.properties 
kafka-server-start.sh $KAFKA_HOME/config/server-1.properties
kafka-server-start.sh $KAFKA_HOME/config/server-2.properties
kafka-server-start.sh $KAFKA_HOME/config/server-3.properties

每个配置文件对应的服务端口是
server.properties 9092 broker=0
server-1.properties 9093 broker=1
server-2.properties 9094 broker=2
server-3.properties 9095 broker=3

zk都是 zookeeper.connect=server00:2181

主机名是 server00

启动后broker1,2,3不能消费
运行命令如下:

    kafka-console-producer.sh --bootstrap-server server00:9093,server00:9094,server00:9095 --topic test05
    kafka-console-consumer.sh --bootstrap-server server00:9093,server00:9094,server00:9095 --topic test05

请帮忙,谢谢

  • 写回答

2条回答 默认 最新

  • AllenGd 大数据领域优质创作者 2023-09-12 18:59
    关注

    试试在启动consumer时指定分区的方式来消费消息:
    kafka-console-consumer.sh --bootstrap-server server00:9093,server00:9094,server00:9095 --topic test05 --partition

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 10月11日
  • 已采纳回答 10月3日
  • 创建了问题 9月11日

悬赏问题

  • ¥20 怎么用dlib库的算法识别小麦病虫害
  • ¥15 华为ensp模拟器中S5700交换机在配置过程中老是反复重启
  • ¥15 java写代码遇到问题,求帮助
  • ¥15 uniapp uview http 如何实现统一的请求异常信息提示?
  • ¥15 有了解d3和topogram.js库的吗?有偿请教
  • ¥100 任意维数的K均值聚类
  • ¥15 stamps做sbas-insar,时序沉降图怎么画
  • ¥15 买了个传感器,根据商家发的代码和步骤使用但是代码报错了不会改,有没有人可以看看
  • ¥15 关于#Java#的问题,如何解决?
  • ¥15 加热介质是液体,换热器壳侧导热系数和总的导热系数怎么算