带有spring kafka的多轮询记录的手动Ack模式
我正在使用SpringKafka消费Kafka的记录。我将max.poll.records设置为300，将enable auto commit设置为false，ack mode设置为Manual。
我想知道，如果100个记录得到了正确的处理，并且我在我的kafkaListener中用确认确认了其中的每一个，现在第101个记录无法被处理，而我没有确认，并且所有剩余的记录也得到了正确的处理（即从第102个到第300个）。1.现在在提交过程中会发生什么？2.我是否会再次收到同一批（第1-300次），或从（第101次）或在第300次之后的记录。
提前道谢。
共有1个答案
使用Kafka时，不确认单个记录，只确认分区内消费者组的一个偏移量。因此，确认较晚的记录将隐式地确认较早的记录。
-
我将Spring和Spring Kafka用于一个批处理服务，该服务从Kafka收集数据，直到满足某些条件，然后转储数据。 我想在数据离开我的服务时确认提交，但它可能会在内存中停留5-10分钟。 是否有任何其他方法来确认/提交来自Spring Kafka的偏移量，只给出分区/偏移量信息？
-
my Listener.AckMode为return并Enable.Auto.Commit设置为false，Partition.Assignment.Strategy：org.apache.kafka.clients.consumer.RoundroBinAssignor 1）我对并发的理解是，由于我将并发（在工厂级别）设置为30，并且我总共有30个分区（用于所有三个主题）可供读取，每个线程将被分
-
问题内容： 如何使用PHP CodeIgniter框架的活动记录查询格式进行UNION查询？ 问题答案： CodeIgniter的ActiveRecord不支持UNION，因此您只需编写查询并使用ActiveRecord的查询方法即可。
-
大家好，我需要为下面的示例创建AVRO模式； 当我按照建议更改所有者对象时，avro-tool返回错误。 ]} 测试：
-
我有一个springboot应用程序，它侦听Kafka流并将记录发送到某个服务以进行进一步处理。服务有时可能会失败。注释中提到了异常情况。到目前为止，我自己模拟了服务成功和异常场景。 侦听器代码： 用户工厂配置如下： 由于REST服务正在抛出RestClientException，它应该进入上面提到的if块。关于FixedBackOff，我不希望SeekToCurrentErrorHandler执
-
使用者配置 Kafka听众 生产者配置