[aerogear-dev] Kafka cdi serialiser problems

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view

[aerogear-dev] Kafka cdi serialiser problems

Hi everyone, 

I'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. 

To test I've updated one of the kafka producers we've implemented to send records with key/value pairs of String/Variant types.

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. 

Here are the updates to the Kafka-cdi library with the serialiser changes: https://github.com/dimitraz/kafka-cdi/commit/09de7ff7c87120f242655253825e4efca186e518

Any help at all would be highly appreciated! 


aerogear-dev mailing list
[hidden email]