| Package | Description | 
|---|---|
| io.druid.indexing.kafka | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaIndexTaskClient | 
KafkaIndexTaskClientFactory.build(TaskInfoProvider taskInfoProvider,
     String dataSource,
     int numThreads,
     org.joda.time.Duration httpTimeout,
     long numRetries)  | 
Copyright © 2011–2018. All rights reserved.