DLQ for Kafka output
Opened this issue · 0 comments
ppf2 commented
Filing a separate issue for #151 (comment) to implement DLQ for Kafka output. This will also help admins capture problem events that are causing exceptions like the following so they can determine the corrective action to take based on the content of the event:
{:exception=>java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.RecordTooLargeException: The message is 12110282 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.}