KafkaMessageDrivenChannelAdapter@Deprecated
public class KafkaHighLevelConsumerMessageSource<K,V>
extends org.springframework.integration.context.IntegrationObjectSupport
implements org.springframework.integration.core.MessageSource<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>>
| Constructor and Description |
|---|
KafkaHighLevelConsumerMessageSource(KafkaConsumerContext<K,V> kafkaConsumerContext)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType()
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.
|
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic KafkaHighLevelConsumerMessageSource(KafkaConsumerContext<K,V> kafkaConsumerContext)
public org.springframework.messaging.Message<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>> receive()
receive in interface org.springframework.integration.core.MessageSource<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>>public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupport