Thanks a lot..
On 29 March 2016 at 14:34, Manikumar Reddy wrote:
> Hi,
>
> You need to implement org.apache.kafka.common.serialization.Serializer,
> org.apache.kafka.common.serialization.Deserializer
> interfaces. Encoder, Decoder interfaces are for older clients.
>
> Example code:
> https://g
Hi,
You need to implement org.apache.kafka.common.serialization.Serializer,
org.apache.kafka.common.serialization.Deserializer
interfaces. Encoder, Decoder interfaces are for older clients.
Example code:
https://github.com/omkreddy/kafka-example
s/tree/master/consumer/src/main/java/kafka/exampl
Hi all;
I have written my custom serialiser/deserializer to publish/consume my java
bean objects.
However i get class nor found exception for "kafka.serializer" packages.
Can someone point me which class i have to use to implement my
custom serializer in kafka 0.9.x?
import kafka.serializer.Decod
