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