Hi Team, need some of your tips and guidance. So I...

# compose

[Anish Nair]

Hi Team, need some of your tips and guidance. So I was writing integration for a KafkaConsumer. This consumer actually utilizes https://github.com/confluentinc/parallel-consumer
to read the events in parallel from the topic A and process it and pushes it to other topics B and C .

So to mock the kafka server I was using testcontainer with image confluentinc/cp-kafka:7.4.0 and created all my topics.

private val kafkaContainer = KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.4.0")).withKraft()

Creation of topic was successfull. For a test data in the kafka topic I'm pushing a sample message by creating producer.

KafkaInit.produceMessage(topic, testMessage)

The issue I face is so when I start my KafkaConsumer for which I'm writing up test. So when I push the test message to the kafka topic and when the KafkaConsumer starts reading it I get the below exception multiple times

Exception caught in user function running stage, registering WC as failed, returning to mailbox. Context: PollContextInternal(pollContext=PollContext
{"stack_trace":"java.lang.ClassCastException: null\n","type":"java.lang.ClassCastException"}

[Stylianos Gakis]

You seem to be in the wrong channel. This is about Jetpack Compose