比方说,我有一个有两个分区的主题-- P1,P2,以及消费者组CG1中的两个消费者C1,C2。现在,每个使用者都在使用来自一个分区的消息。现在这两个消费者都因为某种原因而死了。在这种情况下,
发布于 2020-01-06 14:07:18
3.1经纪人康菲斯默认保留期为7天,即10080分钟,如果使用者在7天内不活动,则将移除该消费者组的抵消项。
offsets.retention.minutes:在消费者群体失去其所有消费者(即变为空)后,其偏移量在被丢弃之前将保留在此保留期内。对于独立的使用者(使用手动分配),补偿将在上次提交加上此保留期之后过期。
Type: intDefault: 10080 Valid Values: [1,...] Importance: highUpdate Mode: read-only检查消费者地位您可以使用以下命令查看每个分区的使用者偏移量
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-grouphttps://stackoverflow.com/questions/59612464
复制相似问题