重新启动kafka服务器后重新读取偏移量
但是如果我们重新启动kafka服务器，使用者会重新读取已经提交的偏移量吗？或者这个选项在这样的情况下工作--服务器重新启动后，只会消耗未读的消息？
共有1个答案
你问（有点）：
使用者是否在提交的偏移量之前重新读取消息？
答案是否定的。一旦在服务器上提交了偏移量，使用者就不会重新读取任何消息（除非他们手动想要）。
-
我有一个单一的Kafka消费者，它连接到一个有3个分区的主题。一旦我从Kafka那里得到一张唱片，我就想捕捉偏移量和分区。在重新启动时，我希望从上次读取的偏移量恢复使用者的位置 摘自Kafka文档： 每个记录都有自己的偏移量，因此要管理自己的偏移量，只需执行以下操作： 配置enable.auto.commit=false 下面是我的示例代码： 这是正确的做法吗？有没有更好的办法？
-
我对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版本的事务。我不知道问题出在哪里。这
-
有一种情况，当消费者1阅读来自Kafka主题的消息时。当使用相同的groupId连接第二个用户2时，需要重新平衡分区。有没有可能以某种方式重置偏移，以便在重新平衡过程之后，两个消费者都从头开始阅读主题？
-
我有： 连接的Kafka消费者 此外，我有一个方法，它接受两个参数：消费者和一个重新平衡侦听器，该侦听器跟踪分配给消费者的分区 此方法在计时器上运行，其目标是处理记录，直到没有剩余的记录可读取，或者直到所有分区中的某个最长时间。 由于重新平衡可能发生在使用过程中（在consumer.poll（）已触发多次之后），因此我希望检测此情况，重置并从所有分配的分区（即使已分配）的最后提交偏移量开始重新启动
-
我们在Android8.1及以上版本中偶然发现了一个我们以前从未见过的问题，不幸的是，这使得我们的应用程序对我们的用户来说不太方便。在Android 8.1及以上版本中，当用户刷屏杀死应用程序时，后台粘性服务不会重新启动。
-
我尝试将auto.offset.reset设置为最早和最晚，但这不会更改行为。 我在消费者配置中遗漏了什么吗？