Open supriya-albal-polestar opened 9 months ago
The deserializer only supports the Kafka protocol binding for cloudevents as per spec https://github.com/cloudevents/spec/blob/main/cloudevents/bindings/kafka-protocol-binding.md, I believe the records are not formatted as expected by the spec ?
I want to take join between a kafka stream and a ktable. The poc works fine with stream data. However, when I use CloudEvent, I keep running into some or other issue related to serialization.
Here is my code sample -
I also tried using WrapperSerde - Issue with configuring Serdes for Kafka Streams
However I keep running into exception -
Am I missing anything, any help from CloudEvent team is appreciated.