javaspringjunitapache-kafkaembedded-kafka

Embedded Kafka Test results fails, curly brackets added to Value

I am using Embedded Kafka Broker at Junits, for testing my values pushed to topic.

I get following error logs.

[ERROR]   KafkaConsumerTest>KafkaConsumerTests.shouldNotRetry4XXResponse:256 

expected: <LocKey(orgId=ORG101, locationType=STORE, locationId=S101)> 

but was: <{"orgId":"ORG101","locationType":"STORE","locationId":"S101"}>

I am comparing keys keys

assertEquals(getKey(), record.getKey());

Somehow, the CURLY BRACKETS are being added to the Received Records from Kafka

Any clues how to get this right, thanks !

Solution

  • I have solved this issue.. the data being published to Kafka was being converted to json before, then published.

    that is why the curly braces got appended

    Abstraction is such a sin !