io.druid.indexing.kafka

Class KafkaIndexTaskClientFactory

java.lang.Object

io.druid.indexing.kafka.KafkaIndexTaskClientFactory

public class KafkaIndexTaskClientFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaIndexTaskClientFactory(HttpClient httpClient, com.fasterxml.jackson.databind.ObjectMapper mapper)

Method Summary

Modifier and Type	Method and Description
KafkaIndexTaskClient	build(TaskInfoProvider taskInfoProvider, String dataSource, int numThreads, org.joda.time.Duration httpTimeout, long numRetries)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaIndexTaskClientFactory

@Inject
public KafkaIndexTaskClientFactory(HttpClient httpClient,
                                           com.fasterxml.jackson.databind.ObjectMapper mapper)

Method Detail

build

public KafkaIndexTaskClient build(TaskInfoProvider taskInfoProvider,
                                  String dataSource,
                                  int numThreads,
                                  org.joda.time.Duration httpTimeout,
                                  long numRetries)