Druid中的Kafka Indexing Service源碼分析

Kafka Indexing Service開發的目的是爲了加強Kafka中數據的實時攝入。其特性以下：數據結構 保障數據攝入的Exactly Once。 能夠攝入任意時間戳的數據，而不單單是當前數據。 能夠根據Kafka分區的變化二調整任務的數量。 影響數據攝入Exactly Once的主要因素是Kafka的Offset管理。Kafka Indexing Service爲了實現Exactly O

>>阅读原文<<