【问题标题】:Consumer only consuming messages when partition number is mentioned消费者仅在提及分区号时才消费消息
【发布时间】:2023-02-17 13:51:58
【问题描述】:

如果您对此有解释,请分享详细信息。

当我尝试使用带有主题名称的 kafka-console-consumer 使用消息时,未使用数据。

bin]# ./kafka-console-consumer --bootstrap-server localhost:9092 --topic test1

但是,当我提到分区号时,消息就会被消耗掉。

bin]# ./kafka-console-consumer --bootstrap-server localhost:9092 --topic test1 --partition 0

test1

test2

test3

【问题讨论】:

  • 您使用的是哪个 Kafka 版本?

标签: apache-kafka kafka-consumer-api


【解决方案1】:

检查 __consumer_offsets 主题是否存在,如果不存在 - 您的配置 offsets.topic.replication.factor 是否高于经纪人的数量?这将导致不创建__consumer_offsets

如果不是这种情况,您可以检查 kafka 日志并使用日志和您环境的详细信息(Kafka 版本等)更新帖子。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2014-02-13
    • 2016-06-12
    • 2020-08-24
    • 1970-01-01
    • 2017-09-23
    • 1970-01-01
    • 2017-03-19
    • 2020-04-19
    相关资源
    最近更新 更多