How to deal with error handling in spring-kafka version 1.1.x
?
相关问题
- Delete Messages from a Topic in Apache Kafka
- How do I identify what code is generating “ '&
- Serializing a serialized Thrift struct to Kafka in
- Spring Integration Kafka vs Spring Kafka
- Kafka broker shutdown while cleaning up log files
相关文章
- <link> onerror do not work in IE
- Could not find default endpoint element that refer
- WPF- validation error event doesn't fire
- What is the direct cause and source of the “Sorry,
- Codeigniter not logging
- Kafka doesn't delete old messages in topics
- Error: “Program type already present: androidx.ver
- Catch an error on requiring module in node.js
In 1.x you can add an
ErrorHandler
implementation to the listener container (or container factory if you are using@KafkaListener
annotations).The 2.0 feature was added to make it easier to configure if you want a different error handler for each listener when using annotations.