How to define multiple serializers in kafka?

2016-05-01 Thread Ratha v
Hi all; Say, I publish and consume different type of java objects.For each I have to define own serializer implementations. How can we provide all implementations in the kafka consumer/producer properties file under the "serializer.class" property? -- -Ratha http://vvratha.blogspot.com/

Re: Invalid TimeStamp Error while running WordCountDemo - kafka-0.10.0

2016-05-01 Thread Guozhang Wang
Hello Buvana, I realized that it is due to a recent change in Kafka Streams exposing an issue in console producer that it does not set the timestamp implicitly while using the new producer. Just filed https://issues.apache.org/jira/browse/KAFKA-3646 for this. As for your case, since you are build