spring - 同一轮询中多条记录的 Spring Kafka 错误处理

Question

我正在使用 Spring Kafka 和错误处理 ( org.springframework.kafka.listener.ErrorHandler)，但我不清楚的是当poll返回多条记录并且只有一条记录导致异常时会发生什么。据我了解，其他记录被跳过。如何实现准时的错误处理（例如仅跳过受影响的记录并继续其他记录）？

标签： springapache-kafkaspring-kafka

Answer 1

请参阅SeekToCurrentErrorHandler- 它对失败的记录以及轮询结果中失败记录之后的任何其他分区执行查找。

当重试次数用尽时，将跳过失败的记录。

一个（ STCEH 是其实现的RemainingRecordsErrorHandler子接口）被给出了剩余记录的列表。ErrorHandler

文档在这里。

使用仅获取失败记录的简单错误处理程序，剩余记录将传递给侦听器（只要不使用事务）。