java嵌入的kafka测试结果失败,花括号增加了值

tyu7yeag  于 2021-06-04  发布在  Kafka
关注(0)|答案(2)|浏览(413)

我在junits上使用嵌入式kafka代理来测试推送到主题的值。
我得到以下错误日志。

[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()); 不知何故,花括号被添加到从Kafka收到的记录
有什么线索吗,谢谢!

lvjbypge

lvjbypge1#

我已经解决了这个问题。。被发布到kafka的数据之前被转换成json,然后被发布。
这就是为什么要加上花括号
抽象是一种罪恶!

xyhw6mcr

xyhw6mcr2#

我更希望您发布整个单元测试,让我们看看Assert之前到底发生了什么,但问题可能出在您对kafka库的序列化器的定义上。似乎您为消息的键定义了一个字符串序列化程序,但您正在尝试将其与对象进行比较。不管怎样,检查你的序列化程序

相关问题