search

bakdata / kafka-error-handling

A library for error handling in Kafka Streams.
MIT License
18 stars 3 forks source link

NPE when adding a header for an exception with a null message #14

Closed pmalon closed 2 years ago

pmalon commented 2 years ago

Stacktrace:

java.lang.NullPointerException: Cannot invoke "String.getBytes(java.nio.charset.Charset)" because "value" is null
14 Jun 2022 16:07:00.808ip-10-3-77-226 reporting[3434]:#011at com.bakdata.kafka.ErrorHeaderTransformer.addHeader(ErrorHeaderTransformer.java:132)
14 Jun 2022 16:07:00.809ip-10-3-77-226 reporting[3434]:#011at com.bakdata.kafka.ErrorHeaderTransformer.transform(ErrorHeaderTransformer.java:118)
14 Jun 2022 16:07:00.809ip-10-3-77-226 reporting[3434]:#011at com.bakdata.kafka.ErrorHeaderTransformer.transform(ErrorHeaderTransformer.java:54)
14 Jun 2022 16:07:00.810ip-10-3-77-226 reporting[3434]:#011at org.apache.kafka.streams.kstream.internals.AbstractStream$1$1.transform(AbstractStream.java:125)
14 Jun 2022 16:07:00.811ip-10-3-77-226 reporting[3434]:#011at org.apache.kafka.streams.kstream.internals.KStreamTransformValues$KStreamTransformValuesProcessor.process(KStreamTransformV

exception happens for a cases when adding EXCEPTION_MESSAGE header for an exception that doesn't include a message

philipp94831 commented 2 years ago

@pmalon Thanks for reporting, we fixed it and released 1.2.5