Details
Major Description
In KIP-210, an exception handler for the write path was introduced. This exception handler covers exception that are raised in the producer callback.
However, serialization happens before the data is handed to the producer with Kafka Streams itself and the producer uses `byte[]/byte[]` key-value-pair types.
Thus, we might want to extend the ProductionExceptionHandler to cover serialization exception, too, to skip over corrupted output messages. An example could be a "String" message that contains invalid JSON and should be serialized as JSON.
KIP-399 (not voted yet; feel free to pick it up): https://cwiki.apache.org/confluence/display/KAFKA/KIP-399%3A+Extend+ProductionExceptionHandler+to+cover+serialization+exceptions
Attachments
Issue Links
- links to
- mentioned in
-
Page Loading...