Embedded Kafka 测试结果失败，大括号添加到 Value

Question

我在 Junits 使用 Embedded Kafka Broker 来测试我的价值观。

我收到以下错误日志。

[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

的 Received Records

任何正确的线索，谢谢！

Answer 1

如果您发布整个单元测试让我们看看在断言之前究竟发生了什么，我会更愿意，但问题可能出在您为 Kafka 库定义序列化程序时。似乎您为消息的键定义了一个字符串序列化程序，但您正试图将它与一个对象进行比较。不管怎样，检查你的序列化程序

Answer 2

我已经解决了这个问题..发布到Kafka的数据之前被转换为json，然后发布。

这就是附加花括号的原因

抽象是一种罪过！

Embedded Kafka 测试结果失败，大括号添加到 Value

Embedded Kafka Test results fails, curly brackets added to Value

java

junit

spring

apache-kafka

embedded-kafka