question Re: Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO in Archives of Support Questions (Read Only) https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146338#M19963 <P><A rel="user" href="https://community.cloudera.com/users/690/adamdoyle.html" nodeid="690">@Adam Doyle</A> </P><P>take a look at this example I'm taking json and serializing it but should be same concept with kryo <A href="https://github.com/dbist/KafkaHBaseBenchmark" target="_blank">https://github.com/dbist/KafkaHBaseBenchmark</A></P><P>MappingConfig.java look at that class</P> Thu, 18 Feb 2016 04:16:53 GMT aervits 2016-02-18T04:16:53Z Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146337#M19962 <P>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. </P> Thu, 18 Feb 2016 03:49:20 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146337#M19962 adam_doyle 2016-02-18T03:49:20Z Re: Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146338#M19963 <P><A rel="user" href="https://community.cloudera.com/users/690/adamdoyle.html" nodeid="690">@Adam Doyle</A> </P><P>take a look at this example I'm taking json and serializing it but should be same concept with kryo <A href="https://github.com/dbist/KafkaHBaseBenchmark" target="_blank">https://github.com/dbist/KafkaHBaseBenchmark</A></P><P>MappingConfig.java look at that class</P> Thu, 18 Feb 2016 04:16:53 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146338#M19963 aervits 2016-02-18T04:16:53Z Re: Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146339#M19964 <P>The solution that ended up working was to adapt the code I found here:</P><P><A href="http://stackoverflow.com/questions/23755976/kafka-writing-custom-serializer" target="_blank">http://stackoverflow.com/questions/23755976/kafka-writing-custom-serializer</A></P> Fri, 19 Feb 2016 04:41:46 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146339#M19964 adam_doyle 2016-02-19T04:41:46Z Re: Looking for an example where using Kryo and Kafka to serialize/deserialize and transfer a POJO https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146340#M19965 <P><A rel="user" href="https://community.cloudera.com/users/690/adamdoyle.html" nodeid="690">@Adam Doyle</A> I have accepted this as best answer. Thanks for the followup!</P> Fri, 19 Feb 2016 04:47:28 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Looking-for-an-example-where-using-Kryo-and-Kafka-to/m-p/146340#M19965 nsabharwal 2016-02-19T04:47:28Z