- I have 2 kafka clusters, one at site1 and other at site2.
- kafka mirroring is enabled on the standby site 2
- I have kafka streams application with state stores configured running on site1.
when I perform switchover and start the same application on site2 I often get deserialization exception like below.
[2023-12-04 18:37:55,761] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:76)
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 22
Caused by: java.io.IOException: Invalid int encoding
I even tried deleting the cleaning state store and recreating it from the topic again but, that does not help. looks like the topic data is corrupted
I am running confluent-5.3.1
can anyone help me here what could be the problem?