search cancel

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

book

Article ID: 257743

calendar_today

Updated On:

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

https://api-broadcom-ca.wolkenservicedesk.com/attachment/get_attachment_content?uniqueFileId=WPW827tqkgKdMp2hQMl7MQ==

Do the same on the Consumer side 

 

 

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

 

Attachments

1673618849118__Getting+Started+with+Apache+Kafka+and+SV.docx get_app