org.springframework.integration.kafka.support
Class ConsumerConfiguration<K,V>
java.lang.Object
org.springframework.integration.kafka.support.ConsumerConfiguration<K,V>
public class ConsumerConfiguration<K,V>
- extends java.lang.Object
- Since:
- 0.5
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConsumerConfiguration
public ConsumerConfiguration(ConsumerMetadata<K,V> consumerMetadata,
ConsumerConnectionProvider consumerConnectionProvider,
MessageLeftOverTracker<K,V> messageLeftOverTracker)
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()