| Package | Description | 
|---|---|
| io.druid.indexing.kafka | |
| io.druid.indexing.kafka.supervisor | 
| Modifier and Type | Method and Description | 
|---|---|
static KafkaTuningConfig | 
KafkaTuningConfig.copyOf(KafkaTuningConfig config)  | 
KafkaTuningConfig | 
KafkaIndexTask.getTuningConfig()  | 
KafkaTuningConfig | 
KafkaTuningConfig.withBasePersistDirectory(File dir)  | 
| Modifier and Type | Method and Description | 
|---|---|
static KafkaTuningConfig | 
KafkaTuningConfig.copyOf(KafkaTuningConfig config)  | 
| Constructor and Description | 
|---|
KafkaIndexTask(String id,
              TaskResource taskResource,
              DataSchema dataSchema,
              KafkaTuningConfig tuningConfig,
              KafkaIOConfig ioConfig,
              Map<String,Object> context,
              ChatHandlerProvider chatHandlerProvider,
              AuthorizerMapper authorizerMapper)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaSupervisorTuningConfig  | 
Copyright © 2011–2018. All rights reserved.