You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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!
The text was updated successfully, but these errors were encountered:
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!
The text was updated successfully, but these errors were encountered: