Thanks a lot.. On 29 March 2016 at 14:34, Manikumar Reddy <ku...@nmsworks.co.in> 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://github.com/omkreddy/kafka-example > s/tree/master/consumer/src/main/java/kafka/examples/common/serialization > > On Tue, Mar 29, 2016 at 8:24 AM, Ratha v <vijayara...@gmail.com> wrote: > > > 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.Decoder; > > import kafka.serializer.Encoder; > > import kafka.utils.VerifiableProperties; > > public class FileSerializer implements Encoder<File>, Decoder<File> { > > > > public FileSerializer() { > > > > } > > > > public RawFileSerializer(VerifiableProperties verifiableProperties) { > > /* This constructor must be present for successful compile. */ > > } > > > > @Override > > public byte[] toBytes(File file) { > > .... > > > > } > > > > @Override > > public File fromBytes(byte[] fileContent) { > > .... > > return (File) obj; > > } > > > > } > > > > > > I have added following pom dependency. > > > > <dependency> > > > > <groupId>org.apache.kafka</groupId> > > > > <artifactId>kafka-clients</artifactId> > > > > <version>0.9.0.0</version> > > > > </dependency> > > > > > > Thanks > > -- > > -Ratha > > http://vvratha.blogspot.com/ > > > -- -Ratha http://vvratha.blogspot.com/
