Kafka give us a lot of options how to handle errors during message processing. Further analysis should be done. It would probably be good to make it configurable.
Some possible options:
- ack all messages and just log the errors
- push the failing message in special error topic and ack
- shutdown the application on error
- (other ?)
Kafka give us a lot of options how to handle errors during message processing. Further analysis should be done. It would probably be good to make it configurable.
Some possible options: