public class ConsumerConnectionProvider
extends java.lang.Object
Constructor and Description |
---|
ConsumerConnectionProvider(kafka.consumer.ConsumerConfig consumerConfig) |
Modifier and Type | Method and Description |
---|---|
kafka.javaapi.consumer.ConsumerConnector |
getConsumerConnector() |