Spring 同一轮询中多条记录的Kafka错误处理
Spring Kafka error handling for multiple record in the same poll
我正在玩 Spring Kafka 和错误处理 (org.springframework.kafka.listener.ErrorHandler) 但我不清楚 poll returns 多条记录和其中只有一个导致异常。据我了解，其他记录被跳过。如何实现准时的错误处理（例如，只跳过受影响的记录并继续处理其他记录）？
查看 SeekToCurrentErrorHandler - 它对失败记录以及轮询结果中失败记录之后的任何其他分区执行查找。
当重试次数用尽时，将跳过失败的记录。
A RemainingRecordsErrorHandler（sub-interface of ErrorHandler 其中 STCEH 是一个实现）给出了剩余记录的列表。
使用仅获取失败记录的简单错误处理程序，其余记录将传递给侦听器（只要未使用事务）。
我正在玩 Spring Kafka 和错误处理 (org.springframework.kafka.listener.ErrorHandler) 但我不清楚 poll returns 多条记录和其中只有一个导致异常。据我了解，其他记录被跳过。如何实现准时的错误处理（例如，只跳过受影响的记录并继续处理其他记录）？
查看 SeekToCurrentErrorHandler - 它对失败记录以及轮询结果中失败记录之后的任何其他分区执行查找。
当重试次数用尽时，将跳过失败的记录。
A RemainingRecordsErrorHandler（sub-interface of ErrorHandler 其中 STCEH 是一个实现）给出了剩余记录的列表。
使用仅获取失败记录的简单错误处理程序，其余记录将传递给侦听器（只要未使用事务）。