org.springframework.integration.kafka.support
Class ConsumerConfiguration<K,V>

java.lang.Object
  extended by org.springframework.integration.kafka.support.ConsumerConfiguration<K,V>

public class ConsumerConfiguration<K,V>
extends java.lang.Object

Since:
0.5

Constructor Summary
ConsumerConfiguration(ConsumerMetadata<K,V> consumerMetadata, ConsumerConnectionProvider consumerConnectionProvider, MessageLeftOverTracker<K,V> messageLeftOverTracker)
           
 
Method Summary
 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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConsumerConfiguration

public ConsumerConfiguration(ConsumerMetadata<K,V> consumerMetadata,
                             ConsumerConnectionProvider consumerConnectionProvider,
                             MessageLeftOverTracker<K,V> messageLeftOverTracker)
Method Detail

setExecutor

public void setExecutor(java.util.concurrent.Executor executor)

getConsumerMetadata

public ConsumerMetadata<K,V> getConsumerMetadata()

receive

public java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>> receive()

createMessageStreamsForTopic

public java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<K,V>>> createMessageStreamsForTopic()

createMessageStreamsForTopicFilter

public java.util.List<kafka.consumer.KafkaStream<K,V>> createMessageStreamsForTopicFilter()

getMaxMessages

public int getMaxMessages()

setMaxMessages

public void setMaxMessages(int maxMessages)

getConsumerConnector

public kafka.javaapi.consumer.ConsumerConnector getConsumerConnector()

shutdown

public void shutdown()