Custom serializer/deserializer for kafka 0.9.x version

[Ratha v]

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/