Kafka Avro Deserializer

[basha-dev-coder]

Hello guys, In my use case, I want to publish and consume Avro messages. I am successfully able to publish an Avro message, but not when consuming the Avro topic. By default, the plugin registers value deserialization as StringDeserializer. This makes it hard to map the messages when I need to match with custom matcher and adding additional checks for the message.

I tried registering with the KafkaAvroDeserializer class, but StringDeserializer is used by default, so I am not able to override the Deseriliaztion. Could you please help me fix this issue?

[Amerousful]

@basha-dev-coder Hi, currently I'm not able to implement this. I could recommend this plugin that supports Avro - https://github.com/galax-io/gatling-kafka-plugin

[basha-sainsburys]

@Amerousful I tried using the above plugin, but I found it difficult to deserialize and map the message. It would be very helpful if we had the flexibility to change the Deserializer class from string to the KafkaAvro class depending on the use case.

I am inclining towards this plugin since it has a very easy method to create custom message matcher logic.

I just want to use register with KafkaAvroDeseriliazer class, after that we can read by using fasterxml or avro library. Hope this makes sense