如何重置偏移值以重新读取 kafka 主题
有一种情况，当消费者1阅读来自Kafka主题的消息时。当使用相同的groupId连接第二个用户2时，需要重新平衡分区。有没有可能以某种方式重置偏移，以便在重新平衡过程之后，两个消费者都从头开始阅读主题？
共有1个答案
我认为，根据您的要求，您可以将偏移值设置为“最早”，这样它就可以从头开始消耗。
有关偏移的更多详细信息，您可以访问这篇文章，它解释了您可以将偏移值设置为什么值[https://dzone . com/articles/Apache-Kafka-consumer-group-offset-retention]
-
但是如果我们重新启动kafka服务器，使用者会重新读取已经提交的偏移量吗？或者这个选项在这样的情况下工作--服务器重新启动后，只会消耗未读的消息？
-
我对Kafka0.11.0.0有意见 在Kafka0.10.2.1中我对此没有任何问题。我只在0.11.0.0版本中遇到这个问题。 我的使用者将auto.offset.reset设置为最早，而auto commit设置为false，因为我是手动提交的。Kafka数据存储在具有必要权限的非TMP目录中。broker配置的其余部分为默认配置。 我需要0.11.0.0版本的事务。我不知道问题出在哪里。这
-
给定主题名、分区号和偏移量，我如何从该主题中读取一条记录？ 在基于Sprng引导的应用程序中，我使用Kafka导入业务数据。导入记录被发送到导入队列，并被一个或多个业务模块使用。即使消费者未能从记录中导入数据以继续从以下记录中导入数据，记录也会始终得到确认。 稍后，用户（在他/她修复了一些相关的业务数据后）可以决定重新发送一个或多个失败（但已确认）的导入记录。 每个记录的偏移量、分区号和主题名都存
-
我有一个单一的Kafka消费者，它连接到一个有3个分区的主题。一旦我从Kafka那里得到一张唱片，我就想捕捉偏移量和分区。在重新启动时，我希望从上次读取的偏移量恢复使用者的位置 摘自Kafka文档： 每个记录都有自己的偏移量，因此要管理自己的偏移量，只需执行以下操作： 配置enable.auto.commit=false 下面是我的示例代码： 这是正确的做法吗？有没有更好的办法？
-
我有一个问题，假设有一个TOPIC T1，有两个消费者C1和C2属于两个不同的组，电流偏移量是0.我们知道Kafka维护消费者的偏移量。因此，如果 C1 使用消息并且 Offset 变为 1，那么如果 C2 使用消息，它将从 1 偏移量开始，还是从 0 偏移量开始使用消息，会发生什么情况？表示两个不同的消费群体将如何维持抵消？ 谢啦
-
简而言之，我想从一开始就对Kafka的数据重新运行Flink管道。 Flink0.10.2，Kafka0.8.2。 我在Kafka中有一个保留2小时的推文主题，以及Flink中的一个管道，该管道以每10秒5分钟的滑动窗口计算推文。 如果我中断管道并重新运行它，我希望它重新读取旧推文，从而发出价值5分钟的推文计数。相反，它似乎从新到达的推文重新开始，因此需要5分钟才能计数为“处于状态”。 我已经尝试