org.springframework.integration.kafka.support
Class KafkaConsumerContext<K,V>
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
KafkaConsumerContext
public KafkaConsumerContext()
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