你能解决我的疑问吗。我可以从jsonobject中得到一个字段 (a-->{"host":"mou","type":"kat"})
在我的Kafka主题中使用了Kafka流,下面的代码是java8。
KStream<String, String> sources = builder
.stream(Serdes.String(), jsonSerde, "example")
.map((k,v) -> new KeyValue<>(k, (String) v.path("a").toString()));
sources.foreach((w, c) -> System.out.println("word: ->" + c));
sources.print("FETCHING FIELD VALUE");
但如果我的意见是 {"type":"","name":"","a"[{"host":"mouni"}]}
我得到序列化错误(请就我的问题发送一份poc。)
1条答案
按热度按时间qojgxg4l1#
用下面的代码行。