我有一个基于字符串的键值对——有大陆和国家的名称。大陆是关键,国家列为价值。我希望它将完整的字符串存储在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));
我想不出下一步要做什么。
暂无答案!
目前还没有任何答案,快来回答吧!