时间戳

首页 > 解决方案 > 嵌入式 Kafka 测试结果失败，大括号添加到 Value

java - 嵌入式 Kafka 测试结果失败，大括号添加到 Value

问题描述

我在 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());

不知何故，花括号被添加到从 Kafka接收的记录中

任何线索如何解决这个问题，谢谢！

标签： javaspringjunitapache-kafkaembedded-kafka

解决方案

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

这就是为什么要附加花括号

抽象是一种罪恶！

推荐阅读