1
A
答えて
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
関連する問題
- 1. Apache Kafkaの利用規約
- 2. Avroスキーマを集中化したApache Kafka
- 3. Apache Nifiでのデータ集約
- 4. Apache Sparkカスタム集約関数
- 5. スパークストリームでの集約
- 6. Apache Pig:FOREACH集約を使用したOutOfMemoryError
- 7. Apache Spark |特定の時間枠集約
- 8. Apache Kafka - テストフォールトトレランス
- 9. Apache Flink Kafka Itegration
- 10. Apache Kafka - コンシューマーファンダメンタルズ
- 11. コンフルエントプラットフォームvs apache kafka
- 12. Apache Kafkaのデータストリームジェネレータ
- 13. イベントvsトピックApache Kafka
- 14. HortonworksのApache kafkaエラー
- 15. Apache Kafkaシステムエラー処理
- 16. Kafka Streaming with apache spark
- 17. Apache Kafka-Zookeeperのプロパティ
- 18. Apache KafkaストリーミングKTableの変更ログ
- 19. Kafkaは単一のログイベントラインを結合ログイベントに集約します
- 20. Apache Kafka複数のコンシューマインスタンス
- 21. Apache IgniteとApache Kafkaの比較
- 22. Apache KafkaでのXml解析
- 23. Apache Kafkaコンソールプロデューサ - コンシューマの例
- 24. angular.js apache kafkaとの統合
- 25. Apache CalciteとKafkaの統合
- 26. Apache kafka - コンシューマー遅延オプション
- 27. セレクタ付きApache Kafkaクライアント?
- 28. Apache KafkaプロデューサコンシューマAPIの問題
- 29. 飼育係、Apache Kafka、Apcahe Storm
- 30. kafka-apache flink実行log4jエラー
感謝あまりにも多くの友達!これは私が探していたものでした!!!! –
もう一度手伝ってください!データをトピックにプッシュしながら、カフカが集計をリアルタイムで行う方法はありますか? –
Kafkaは、内部のレコードキャッシュを無効にして、アップデートをより迅速に取得したい場合があります。 'StreamsConfig'で' cache.max.bytes.buffering'をゼロに設定してください。 Cf。 http://docs.confluent.io/current/streams/developer-guide.html#memory-management –