CODEWITHSUNDEEP
apache-kafkaspring-cloudapache-kafka-streamsspring-cloud-stream
Shreya Garg
Shreya Garg

Reputation: 51

Kafka streams Deserialisation exception| Log and continue e

I am facing the same issue as Kafka Streams Deserialization Handler

After using logandcontinue, still on restarting server the corrupt messages show up everytime.

Upvotes: 0

Views: 640

Answers (1)

sobychacko
sobychacko

Reputation: 5924

It looks like this jira issue is still open and needs to be addressed to fix the problem you are describing: https://issues.apache.org/jira/browse/KAFKA-6502

It only happens when you have a series of records in error though. As soon as you have a good record coming in, the offset moves along. Therefore, as a workaround, you can probably send a good record that will not cause an error maybe?

Upvotes: 1

Related Questions