Kafka streams is getting shutdown when there is a deserialisation error while consuming the message #40470
Closed
DurgaManasaMaruboyina
started this conversation in
Community
Replies: 1 comment
-
We found the fix. This is how we should use the property as: |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
We are using kafka streams with quarkus. The kafka streams is getting shutdown and not processing further messages when there is a deserialisation issue while consuming a message. We tried to set the application properties which does
logAndContinue
. Somehow it's not working and the streams is getting shutdown.We tried the below options:
default.deserialization.exception.handler=org.apache.kafka.streams.errors.LogAndContinueExceptionHandler
quarkus.kafka.streams.default-deserialization-exception-handler=org.apache.kafka.streams.errors.LogAndContinueExceptionHandler
Could someone help us to resolve this issue?
Beta Was this translation helpful? Give feedback.
All reactions