<div dir="ltr">Hi everyone, <div><br></div><div>I&#39;m currently trying to add a generic serializer/deserializer to the kafka CDI library that allows producers and consumers to handle objects of type T. </div><div><br></div><div>To test I&#39;ve updated one of the kafka producers we&#39;ve implemented to send records with key/value pairs of String/Variant types.</div><div><br></div><div>As far as I can tell the Serdes are actually being returned, but for some reason I cannot seem to grasp, the GenericSerializer class is being called again (not using the overlaoded constructor which is necessary to pass in the type of the object) and a NullPointerException is then thrown. </div><div><br></div><div>Here is the updated producer: <a href="https://github.com/dimitraz/aerogear-unifiedpush-server/commit/cbc3b3da867fcef17ec419edee13a30d8c938dae">https://github.com/dimitraz/aerogear-unifiedpush-server/commit/cbc3b3da867fcef17ec419edee13a30d8c938dae</a></div><div><br></div><div>Here are the updates to the Kafka-cdi library with the serialiser changes: <a href="https://github.com/dimitraz/kafka-cdi/commit/09de7ff7c87120f242655253825e4efca186e518">https://github.com/dimitraz/kafka-cdi/commit/09de7ff7c87120f242655253825e4efca186e518</a></div><div><br></div><div>Any help at all would be highly appreciated! </div><div><br></div><div>Dimitra</div></div>