如何重置偏移值以重新读取kafka主题

【问题标题】：How to reset the offset value to re-read the kafka topic如何重置偏移值以重新读取kafka主题
【发布时间】：2021-10-05 11:38:08
【问题描述】：

有一种情况是Consumer1从kafka topic中读取消息。当用相同的 groupId 连接第二个 Consumer2 时，会重新平衡分区。是否有可能以某种方式重置偏移量，以便在重新平衡过程之后，两个消费者都从头开始阅读主题？

【问题讨论】：

你试过seekToBeginning吗？
@OneCricketeer，不，我对kafka的了解不是很深，我该怎么做？
这是消费者实例上的一个方法。请参阅此处的示例stackoverflow.com/questions/40352008/…

标签： java spring-boot apache-kafka

【解决方案1】：

我认为根据您的要求，您可以将偏移值设置为 Earliest ，以便从头开始使用。

有关偏移量的更多详细信息，您可以访问这篇文章，该文章解释了您可以将偏移值设置为 [https://dzone.com/articles/apache-kafka-consumer-group-offset-retention]

【讨论】：

auto.offset.reset 仅适用于不存在的消费者群体

猜你喜欢

2019-01-06
2017-01-31
2019-07-20
2018-01-22
2021-08-16
2016-05-27
1970-01-01
2017-03-09
2017-12-12

相关资源

下载 2023-01-28
下载 2021-06-06
下载 2022-12-07

最近更新更多

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode