Matthias J. Sax created KAFKA-20439:
---------------------------------------

             Summary: Allow to write dropped records in the DLQ
                 Key: KAFKA-20439
                 URL: https://issues.apache.org/jira/browse/KAFKA-20439
             Project: Kafka
          Issue Type: New Feature
          Components: streams
            Reporter: Matthias J. Sax


Some operators in the Kafka Streams DSL may drop malformed records which cannot 
be processed correctly (eg, records with null-key). Atm, we track this via a 
JMX metric.

We recently added DLQ support to Kafka Streams, however, it doesn't cover 
records dropped by the DSL.

We propose to allow capturing records dropped by the DSL and write into the DLQ.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to