2017-04-07 74 views

回答

2

我不熟悉Apache的駱駝,但你可以用卡夫卡流聚集傳遞消息:

我指的是文檔現在:http://docs.confluent.io/current/streams/developer-guide.html#streams-developer-guide-dsl-aggregating

還檢查了例子:https://github.com/confluentinc/examples/tree/3.2.x/kafka-streams

+0

謝謝你這麼多哥們!這是我正在尋找的那個! –

+0

多一個幫助!有什麼方法卡夫卡將實時聚合,而推動數據主題! –

+0

卡夫卡確實 - 你可能想要禁用內部記錄緩存來獲取更新更快。在'StreamsConfig'中設置'cache.max.bytes.buffering'爲零。參看http://docs.confluent.io/current/streams/developer-guide.html#memory-management –