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

java.lang.Object
  extended by org.springframework.integration.kafka.support.KafkaConsumerContext<K,V>
All Implemented Interfaces:
org.springframework.beans.factory.DisposableBean

public class KafkaConsumerContext<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.DisposableBean

Since:
0.5

Constructor Summary
KafkaConsumerContext()
           
 
Method Summary
 void destroy()
           
 ConsumerConfiguration<K,V> getConsumerConfiguration(java.lang.String groupId)
           
 java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> getConsumerConfigurations()
           
 java.lang.String getConsumerTimeout()
           
 ZookeeperConnect getZookeeperConnect()
           
 org.springframework.messaging.Message<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>> receive()
           
 void setConsumerConfigurations(java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> consumerConfigurations)
           
 void setConsumerTimeout(java.lang.String consumerTimeout)
           
 void setZookeeperConnect(ZookeeperConnect zookeeperConnect)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KafkaConsumerContext

public KafkaConsumerContext()
Method Detail

getConsumerTimeout

public java.lang.String getConsumerTimeout()

setConsumerTimeout

public void setConsumerTimeout(java.lang.String consumerTimeout)

getZookeeperConnect

public ZookeeperConnect getZookeeperConnect()

setZookeeperConnect

public void setZookeeperConnect(ZookeeperConnect zookeeperConnect)

setConsumerConfigurations

public void setConsumerConfigurations(java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> consumerConfigurations)

getConsumerConfigurations

public java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> getConsumerConfigurations()

getConsumerConfiguration

public ConsumerConfiguration<K,V> getConsumerConfiguration(java.lang.String groupId)

receive

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

destroy

public void destroy()
             throws java.lang.Exception
Specified by:
destroy in interface org.springframework.beans.factory.DisposableBean
Throws:
java.lang.Exception