Kafka未能跟踪最后一次提交的抵消
- Spring-Boot版本--2.2.6发行版
- Spring-Kafka-2.3.7发行版
- Kafka-客户端-2.3.1
- 阿帕奇-Kafka-Kafka2.12-2.3.1
我们有10个主题和50个分区，每个主题属于同一组，我们增加主题分区和用户计数在运行时根据负载。
- 自动提交=false
- 处理后同步提交每个偏移量
- max-poll-records设置为1
共有1个答案
您需要确保：
1）您使用的是相同的使用者组ID
2）auto.offset.reset设置为lates
spring.kafka.consumer.group-id=your-consumer-group-id
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.enable-auto-commit=true
-
我正在使用admin client API查询kafka broker，以使用以下代码获取CONSUMER_GROUP的提交偏移量： 上述代码将触发对特殊创建的_consumer_offsets主题的查询，以获取主题的每个分区（consumer_GROUP负责的分区）的提交偏移量。 另一方面，我使用下面的代码检索CONSUMER_GROUP的每个主题分区的最新（结束）偏移量 我的问题是，已提交和最
-
我正在ThreadPoolExecutor中运行多个任务。我将其初始化如下： 我自己实现了runnable（），其中包含一个方法来跟踪提交任务的进度。我提交的实例如下： 我正在寻找一种查询当前/挂起线程的执行器/阻塞队列的方法。我尝试使用jobQueue。toArray（）和重写executor方法但在这两种情况下，返回的Runnable都是FutureTask类型，不包含太多数据。有没有一种方法
-
根据我的理解，消费者阅读特定主题的消息，并且消费者客户机将定期提交偏移量。 因此，如果由于某种原因，使用者失败了一个特定的消息，该偏移量将不会被提交，然后您可以返回并重新处理该消息。 是否有任何东西跟踪您刚刚消耗的偏移和您随后提交的偏移？
-
问题内容： 我有一个page1.php，我有一个fly.php。page1.php是一个简单的（常规）表单页面，当用户提交表单时，人们会在其中放置信息。 通过ajax，它加载验证码模板，并要求即时验证（直到这里很好）。 经过onFly验证后，我要允许此.submit（）继续 问题：此验证码中的n个，并在验证成功之后，恢复表单提交（处于保留状态）？ 例： 第1部分：page1.php 第2部分：fl
-
此cPanel接口用于查看电子邮件的发送报告。 此界面可以在发送电子邮件时显示错误。 您还可以查看电子邮件的垃圾邮件分数。 Apache Spamassassin提供垃圾邮件分数。 您还可以查看电子邮件递送路线，以帮助您识别递送尝试中的任何问题。 要跟踪电子邮件传递，请通过单击cPanel的“电子邮件”部分中的“跟踪传递”链接打开cPanel Track Delivery。 在track Deli
-
我有一个Kafka的题目有1个分区。如果它有100条消息，偏移量将从0.99开始。 根据Kafka保留策略，在指定的时间之后，所有的消息都将被清除。 并且我正在发送100个新的消息到主题，一旦所有已经被清除（在保留期之后）。现在，消息的新偏移量从哪里开始呢？是从100还是从0？？ 我想知道新的偏移是100-199还是0-99？