KAFKA set up in DEVTEST 10.7.2-Error deserializing key/value for partition ci.alerts.realtime.outbound-7 at offset 52961246

Products

• Service Virtualization

Issue/Introduction

I need help in creating virtual service which can simulate kafka consumer & producer. I have created assets for kafka topic, consumer, producer & kafka connection. I do not see any issue while testing these assets from DevTest workstation but while recording the virtual service or just publishing and subscribing,  I am getting errors. 

 

STACK TRACE
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition ci.alerts.realtime.outbound-7 at offset 52961246. If needed, please seek past the record to continue consumption.
Caused by: org.apache.kafka.common.errors.SerializationException: Error when deserializing byte[] to string due to unsupported encoding org.apache.kafka.common.serialization.StringSerializer
============================================================================

    at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils.poll(KafkaUtils.java:256)
    at com.itko.lisa.messaging.providers.kafka.asset.KafkaAsyncListener.run(KafkaAsyncListener.java:187)
    at java.lang.Thread.run(Thread.java:748)
============================================================================

 

Environment

Release :

Cause

Encoding is not valid

Resolution

In the Producer, you can configure the serializers used for the message Key and Value to use UTF-8 encoding

Do the same on the Consumer side 

 

 

Note:Please refer to the Kafka set up documentation that is attached.