如何重置offset值来重新阅读Kafka主题

tf7tbtn2 于 2023-04-19 发布在 Apache

关注(0)|答案(2)|浏览(195)

Consumer1读取Kafka topic的消息时，连接第二个Consumer2时，同一个groupId会出现分区重新平衡的情况，是否可以通过某种方式重置offset*，这样重新平衡后，两个Consumer2都会从头读取topic？

apache-kafka

来源：https://stackoverflow.com/questions/68582251/how-to-reset-the-offset-value-to-re-read-the-kafka-topic

2条答案

按热度按时间

tcomlyy61#

我想根据您的要求，可以将偏移量设置为Earliest，这样可以从头开始消耗。
有关偏移量的更多详细信息，您可以访问这篇文章，其中解释了可以将偏移量值设置为https://dzone.com/articles/apache-kafka-consumer-group-offset-retention(https://dzone.com/articles/apache-kafka-consumer-group-offset-retention)的值

赞(0）回复(0）举报 2023-04-19

nfs0ujit2#

关闭消费者组中的所有消费者，然后执行以下操作：

$ kafka-consumer-groups --bootstrap-server kafka:9092 --group my-special-consumer --topic car-positions --reset-offsets --to-earliest

赞(0）回复(0）举报 2023-04-19

我来回答

如何重置offset值来重新阅读Kafka主题

2条答案

相关问题

热门标签

最新问答