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, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, 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