小编Man*_*anu的帖子

Kafka 消费者没有消费来自所有分区的消息

我创建了一个具有 10 个分区的 Kafka 主题,并尝试通过单个 kafka 消费者来消费消息。但是,kafka 消费者不会从所有分区读取消息。更具体地说,它仅使用来自 5 个特定分区的消息。 示例:消费者仅使用来自 [0,1,2,3,4] 的消息。重新启动后,如果它开始消费来自 [5,6,7,8 ,9] 的消息,那么它只会消费来自这些分区的消息。这是 kafka-consumer-offset-checker.sh 命令的输出

群组|主题| PID | 偏移| 日志大小| 滞后 | 所有者
GRP1 | 主题1 | 0 | 128 | 175 | 47 | 没有任何
GRP1 | 主题1 | 1 | 117 | 146 | 29 | 没有任何
GRP1 | 主题1 | 2 | 62 | 87 | 25 | 没有任何
GRP1 | 主题1 | 3 | 101 | 143 | 42 | 没有任何
GRP1 …

apache-kafka kafka-consumer-api

6
推荐指数
1
解决办法
5592
查看次数

标签 统计

apache-kafka ×1

kafka-consumer-api ×1