druid/extensions-core/kafka-indexing-service
Gian Merlino f22fb2c2cf KafkaIndexTask.
Reads a specific offset range from specific partitions, and can use dataSource metadata
transactions to guarantee exactly-once ingestion.

Each task has a finite lifecycle, so it is expected that some process will be supervising
existing tasks and creating new ones when needed.
2016-03-10 18:41:43 -08:00
..
src KafkaIndexTask. 2016-03-10 18:41:43 -08:00
pom.xml KafkaIndexTask. 2016-03-10 18:41:43 -08:00