Re: Kafka Help

2018-12-05 Thread Matthias J. Sax
You will need to write a custom deserializer that is able to convert he `byte[]` of key and value into the desired Scala/Java object. Interface: org.apache.kafka.common.serialization.Deserializer You can provide your custom deserializer via config to console consumer and KafkaConsumer in your Sca

Kafka Help

2018-12-05 Thread kalpana more
Dear Team, I want to convert the c++ struct data. I have the data which is send from tcp port to kafka using c++ ,so the data in kafka topic is in c++ struct format. I am not able to print that struct data on console and not able to streaming that data using scala. Could you help me how to solve