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