SeekToCurrentBatchErrorHandler 已弃用,但在 Kafka Binder 参考指南中有建议
SeekToCurrentBatchErrorHandler deprecated but suggested in the Kafka Binder Reference Guide
Spring Cloud Stream Kafka Binder 参考指南指出,在批处理消费者中,可以配置 SeekToCurrentBatchErrorHandler 来实现重试功能。
然而,SeekToCurrentBatchErrorHandler 已被弃用,取而代之的是 DefaultErrorHandler。
那么在 Spring Cloud Stream Kafka 的批量消费者中获得重复行为的正确方法是什么?
见Legacy Error Handlers and Their Replacements。
SeekToCurrentBatchErrorHandler
No replacement, use DefaultErrorHandler with an infinite BackOff.
但是,有更好的方法来处理批处理侦听器的错误;见 https://docs.spring.io/spring-kafka/docs/current/reference/html/#annotation-error-handling
应该更新 SCSt 文档;我建议你在那里打开一个问题 https://github.com/spring-cloud/spring-cloud-stream/issues
Spring Cloud Stream Kafka Binder 参考指南指出,在批处理消费者中,可以配置 SeekToCurrentBatchErrorHandler 来实现重试功能。 然而,SeekToCurrentBatchErrorHandler 已被弃用,取而代之的是 DefaultErrorHandler。 那么在 Spring Cloud Stream Kafka 的批量消费者中获得重复行为的正确方法是什么?
见Legacy Error Handlers and Their Replacements。
SeekToCurrentBatchErrorHandler
No replacement, use DefaultErrorHandler with an infinite BackOff.
但是,有更好的方法来处理批处理侦听器的错误;见 https://docs.spring.io/spring-kafka/docs/current/reference/html/#annotation-error-handling
应该更新 SCSt 文档;我建议你在那里打开一个问题 https://github.com/spring-cloud/spring-cloud-stream/issues