消费者重复事件
我们观察到，其中一位消费者多次试图从Kafka主题中选取事件。我们在消费者应用程序方面有以下内容。spring.kafka.consumer.enable auto commit=false
共有1个答案
由于您已经禁用了自动提交，因此您确实需要在实际提交记录时进行微调，否则您至少可以进行一次处理。
您还可以阅读使用事务和幂等生产者的恰好一次处理功能的示例
auto.offset.reset仅适用于您的消费者组被删除或根本不存在的情况（您没有提交任何内容）。在这种情况下，您总是要从主题的开头开始阅读
-
for循环和foreach可以使用break指令。而是Java8消费者。
-
在我们的spring boot应用程序中，我们注意到Kafka消费者偶尔会在prod env中随机消费两次消息。我们在PCF中部署了6个实例和6个分区。我们发现在同一主题中收到两次具有相同偏移量和分区的消息，这会导致重复，对我们来说是业务关键。我们在非生产环境中没有注意到这一点，在非生产环境中很难复制。我们最近转向Kafka，但我们无法找到根本问题。 我们使用的是spring cloud stre
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
问题是Spring Kafka侦听器只配置了主题名。 我似乎可以让Kafka产生100个消费者来处理来自“队列”（日志）的消息。怎么能做到呢？
-
我们有一个制作人 在开发过程中，我重新部署了producer应用程序，并做了一些更改。但在此之后，我的消费者没有收到任何消息。我尝试重新启动消费者，但没有成功。问题可能是什么和/或如何解决？ 消费者配置： 生产者配置： 编辑2： 5分钟后，消费者应用程序死亡，但以下情况除外：
-
我花了几个小时想弄清楚发生了什么，但没能找到解决办法。 这是我在一台机器上的设置： 1名zookeeper跑步 我正在使用kafka控制台生成器插入消息。如果我检查复制偏移量（