Versions Compared


  • This line was added.
  • This line was removed.
  • Formatting was changed.


This KIP is aimed at improving the error-handling semantics in Kafka Streams when Kafka Steams fails to serialize a message to the downstream sink by providing an interface that can provide custom messaging of the error (e.g. report to a custom metrics system) and indicate to Streams whether or not it should re-throw the Exception, thus causing the application to fall over.


Current state: Under Discussion Accepted

Discussion thread: here