Hi there,
I have been trying to use both the Kafka event listener in the server and the Kafka reader in the designer to read from some Kafka topics. It works well for reading from some of the topics but for others I get errors like this
Received exception when fetching the next record from . If needed, please seek past the record to continue consumption.
Could not initialize class org.apache.kafka.common.record.CompressionType$SnappyConstructors
I have tried deserialising it as bytes as well as a string type but still get the same error. I have also gotten a similar error for another topic
Received exception when fetching the next record from . If needed, please seek past the record to continue consumption.
Could not initialize class org.xerial.snappy.SnappyInputStream
I’m not sure what is causing the errors for some topics and not other so any help would be appreciated
Thank you!