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) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType() |
org.springframework.messaging.Message<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>> |
receive() |
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public 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.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport