例如， 如果 kafka 主题中的数据看起来像这样
{
\"header\": {
\"name\": \"jake\"
},
\"body\": {
\"Data\":\"!#$%&&\"
}
}
那么如何从我的消费者应用程序中读取值 \"!#$%&&\" ？获得数据后，我需要处理数据
标签： json apache-kafka apache-kafka-streams
您需要使用 String Serde、JSON Serde 或定义自己的数据来使用数据。
如果您定义自己的，那么您将调用 value.getBody().getData()，就像任何其他 Java 对象一样，其中 value 是来自 mapValues、peek、filter 等的参数。Kafka Streams DSL
对于其他人，答案将取决于您使用的 JSON 库，但答案并不是 Kafka 独有的，因此请阅读该库关于解析字符串的文档。
这是使用 String Serde 进行消费的一个示例 - https://github.com/confluentinc/kafka-streams-examples/blob/7.1.1-post/src/main/java/io/confluent/examples/streams/JsonToAvroExample.java#L118
【讨论】：