Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO

[#1]

I am having trouble finding an example where someone serializes and deserializes a POJO over a Kafka queue. I can send simple strings across, but when I serialize and send a more complex object, I've been getting BufferUnderflows and ArrayOutOfBoundsExceptions.

[#2]

@Adam Doyle

take a look at this example I'm taking json and serializing it but should be same concept with kryo https://github.com/dbist/KafkaHBaseBenchmark

MappingConfig.java look at that class

[#3 · Accepted solution]

The solution that ended up working was to adapt the code I found here:

http://stackoverflow.com/questions/23755976/kafka-writing-custom-serializer

[#4]

@Adam Doyle I have accepted this as best answer. Thanks for the followup!