kakfa-group-by-key并附加所有值并返回字符串

0lvr5msh  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(174)

我有一个基于字符串的键值对——有大陆和国家的名称。大陆是关键,国家列为价值。我希望它将完整的字符串存储在kafka主题中,key作为大陆名称,value作为国家名称。

kafkaTemplate.send("testkafkatopic", key, value)

现在,我想要求返回每个大陆的完整国家名单。

StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> stream =
builder.stream("testkafkatopic", Consumed.with(Serdes.String(), Serdes.String()));
KGroupedStream<String, String> kGroupedStream = stream.groupByKey();
kGroupedStream.windowedBy(TimeWindows.of(60000L));

我想不出下一步要做什么。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题