Результаты встроенного теста Kafka не проходят, значение добавлено в фигурные скобки

Question

Я использую Embedded Kafka Broker в Junits, для тестирования моих значений, помещенных в topi c.

Я получаю следующие журналы ошибок.

[ERROR]   KafkaConsumerTest>KafkaConsumerTests.shouldNotRetry4XXResponse:256 

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

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

Я сравниваю ключи ключей

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

Каким-то образом CURLY BRACKETS добавляются к Полученным записям от Kafka

Любые подсказки, как это сделать, спасибо!

Answer 1

Я решил эту проблему .. данные, публикуемые в Kafka, ранее конвертировались в json, а затем публиковались.

поэтому были добавлены фигурные скобки

Абстракция - это такой грех!

Answer 2

Я бы предпочел, чтобы вы опубликовали для нас весь модульный тест, чтобы мы могли увидеть, что именно происходит до утверждения, но проблема, вероятно, заключается в вашем определении сериализаторов для библиотеки Kafka. Похоже, вы определили сериализатор строк для ключа сообщения, но вы пытаетесь сравнить его с объектом. В любом случае, проверьте сериализаторы