logstash-plugins/logstash-output-kafka

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.}