Versions Compared

Key

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

...

  1. ClassCastException is thrown while serializing record key / value. Today, we are throwing StreamsException on hitting this exception. Whether to throw the
    exception to the user will be decided based on the response received from ProductionExceptionHandler handleSerializationException method. 
  2. If the result is CONTINUE, log a note at DEBUG that we received that result and are not failing Streams as a result.
  3. If the result is FAIL, log a message at ERROR that we received that result and throw StreamsException so Streams will fail.We will continue to throw this exception and not invoke the new method.  This will allow the current behavior to continue as this can help identify misconfigured serdes 
  4. Any other unchecked exceptions, that thrown during record key / value serialization.
    1. If the result is CONTINUE, log a note at DEBUG that we received that result and are not failing Streams as a result.
    2. If the result is FAIL, log a message at ERROR that we received that result and set sendException so Streams will fail.

...