public class ConsumerConfiguration<K,V>
extends java.lang.Object
Constructor and Description |
---|
ConsumerConfiguration(ConsumerMetadata<K,V> consumerMetadata,
ConsumerConnectionProvider consumerConnectionProvider,
MessageLeftOverTracker<K,V> messageLeftOverTracker) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<K,V>>> |
createMessageStreamsForTopic() |
java.util.List<kafka.consumer.KafkaStream<K,V>> |
createMessageStreamsForTopicFilter() |
kafka.javaapi.consumer.ConsumerConnector |
getConsumerConnector() |
ConsumerMetadata<K,V> |
getConsumerMetadata() |
int |
getMaxMessages() |
java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>> |
receive() |
void |
setExecutor(java.util.concurrent.Executor executor) |
void |
setMaxMessages(int maxMessages) |
void |
shutdown() |
public ConsumerConfiguration(ConsumerMetadata<K,V> consumerMetadata, ConsumerConnectionProvider consumerConnectionProvider, MessageLeftOverTracker<K,V> messageLeftOverTracker)
public void setExecutor(java.util.concurrent.Executor executor)
public ConsumerMetadata<K,V> getConsumerMetadata()
public java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>> receive()
public java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<K,V>>> createMessageStreamsForTopic()
public java.util.List<kafka.consumer.KafkaStream<K,V>> createMessageStreamsForTopicFilter()
public int getMaxMessages()
public void setMaxMessages(int maxMessages)
public kafka.javaapi.consumer.ConsumerConnector getConsumerConnector()
public void shutdown()