public class KafkaConsumerContext<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.BeanFactoryAware
| Constructor and Description |
|---|
KafkaConsumerContext() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Collection<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 |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConsumerTimeout(java.lang.String consumerTimeout) |
void |
setZookeeperConnect(ZookeeperConnect zookeeperConnect) |
public java.util.Collection<ConsumerConfiguration<K,V>> getConsumerConfigurations()
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
throws org.springframework.beans.BeansException
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwareorg.springframework.beans.BeansExceptionpublic org.springframework.messaging.Message<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>> receive()
public java.lang.String getConsumerTimeout()
public void setConsumerTimeout(java.lang.String consumerTimeout)
public ZookeeperConnect getZookeeperConnect()
public void setZookeeperConnect(ZookeeperConnect zookeeperConnect)