Re: Kafka stream api to consume json values using kafka connect json deserializer

2017-10-04 Thread Ted Yu
Have you taken a look at streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java ? final Deserializer jsonDeserializer = new JsonDeserializer(); final Serde jsonSerde = Serdes.serdeFrom(jsonSerializer, jsonDeserializer); final Co

Kafka stream api to consume json values using kafka connect json deserializer

2017-10-04 Thread Phani Kumar Yadavilli -X (phyadavi - ALLEGIS SERVICES INDIA PRIVATE LIMITED at Cisco)
Hi Everyone, I am a newbie to kafka and kafka streams api. I am trying to consume a json message using kafka connect api in kafka streams. I tried searching in google but i could not find any substantial information on how to read json message in streams api. Therefore, with the limited knowl