Sometimes Retrying is not an option, you want to skip the message and continue and perhaps let another consumer deal with the failed messages. The documentation currently recommends that for the RESUME_AT_NEXT_RECORD error strategy, but each developer has to code that. There are some issues with that too: #110
It would be great to:
Divert error messages to a configured DLQ (Dead Letter Queue)
Include the error/exception in a header
Include the topic/offset/partition where the failed messages was
and resume on next record
Configuration:
@KafkaListener(
value = "myGroup",
errorStrategy = @ErrorStrategy(
value = ErrorStrategyValue.LOG_AND_RESUME_AT_NEXT_RECORD,
dlq = "${my.dlq.topic.name}"
)
)
Feature description
Sometimes Retrying is not an option, you want to skip the message and continue and perhaps let another consumer deal with the failed messages. The documentation currently recommends that for the RESUME_AT_NEXT_RECORD error strategy, but each developer has to code that. There are some issues with that too: #110
It would be great to:
Configuration: