Druid中的Kafka Indexing Service源碼分析

2018年04月08日 22:23:15 閱讀數：129 Kafka Indexing Service開發的目的是爲了增強Kafka中數據的實時攝入。其特性如下： 保障數據攝入的Exactly Once。 可以攝入任意時間戳的數據，而不僅僅是當前數據。 可以根據Kafka分區的變化二調整任務的數量。 影響數據攝入Exactly Once的主要因素是Kafka的Offset管理。Kafka Inde

>>阅读原文<<