public class KafkaConsumerContext<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.DisposableBean
Constructor and Description |
---|
KafkaConsumerContext() |
Modifier and Type | Method and Description |
---|---|
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) |
public java.lang.String getConsumerTimeout()
public void setConsumerTimeout(java.lang.String consumerTimeout)
public ZookeeperConnect getZookeeperConnect()
public void setZookeeperConnect(ZookeeperConnect zookeeperConnect)
public void setConsumerConfigurations(java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> consumerConfigurations)
public java.util.Map<java.lang.String,ConsumerConfiguration<K,V>> getConsumerConfigurations()
public ConsumerConfiguration<K,V> getConsumerConfiguration(java.lang.String groupId)
public org.springframework.messaging.Message<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>> receive()
public void destroy() throws java.lang.Exception
destroy
in interface org.springframework.beans.factory.DisposableBean
java.lang.Exception