I am creating a simple "Hello World" Kafka Streaming application. My Producer is producing protobuf serialize messages to one topic and I'm using that topic in Kafka Streaming application to consumer messages. I'm trying to deserialize messages using (valueSerde: io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde) in my application.yml file. I don't find any proper example for KafkaProtobufSerde to serialize/deserialize in the Kafka stream. Can you implement a sample example with proper binding so I can get more clarification.
If you need any other information then please let me know!
Hello,
I am creating a simple "Hello World" Kafka Streaming application. My Producer is producing protobuf serialize messages to one topic and I'm using that topic in Kafka Streaming application to consumer messages. I'm trying to deserialize messages using (valueSerde: io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde) in my application.yml file. I don't find any proper example for KafkaProtobufSerde to serialize/deserialize in the Kafka stream. Can you implement a sample example with proper binding so I can get more clarification.
If you need any other information then please let me know!
Thank you so much!