我想做的是:使用數字主題(Long‘s)中的記錄匯總(計數)每5秒窗口的值將最終聚合結果發送到另一個主題我的代碼看起來如下:KStream<String, Long> longs = builder.stream(
Serdes.String(), Serdes.Long(), "longs");
// In one ktable, count by key, on a five second tumbling window.
KTable<Windowed<String>, Long> longCounts =
longs.countByKey(TimeWindows.of("longCounts", 5000L));
// Finally, sink to the long-avgs topic.
longCounts.toStream((wk, v) -> wk.key())
.to("long-counts");看起來一切都像預期的那樣工作,但是聚合被發送到每個傳入記錄的目標主題。我的問題是如何只發送每個窗口的最終聚合結果?
2 回答
慕哥9229398
TA貢獻1877條經驗 獲得超6個贊
添加回答
舉報
0/150
提交
取消
