KafkaConsumer Error setting up Kafka recorder in DevTest

Products

• CA Application Test
• Service Virtualization

Issue/Introduction

Trying to setup Kafka recorder getting the following error when trying to start.   

java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

 

Environment

Release : All supported DevTest versions

Component : CA Service Virtualization

Cause

KafkaConsumer is not safe for multi-threaded access.

Using the same topic(SV_TOPIC_IMS_Lab) for Request and Response while recording. 

Resolution

For Kafka recorder, please use different topics for the Request topic and the Response topic  while recording. 

Like for example : SV_TOPIC_IMS_Lab_Request and SV_TOPIC_IMS_Lab_response.