public class KafkaHighLevelConsumerMessageSourceSpec extends MessageSourceSpec<KafkaHighLevelConsumerMessageSourceSpec,org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?>> implements ComponentsRegistration
MessageSourceSpec
for KafkaHighLevelConsumerMessageSource
.Modifier and Type | Class and Description |
---|---|
class |
KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec
A helper class in the Builder pattern style to delegate options to the
ConsumerMetadata
and populate ConsumerConfiguration . |
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
KafkaHighLevelConsumerMessageSourceSpec |
addConsumer(java.lang.String groupId,
Consumer<KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec> consumerMetadataSpec)
Add Kafka High Level Consumer to this
KafkaHighLevelConsumerMessageSource
under provided groupId . |
KafkaHighLevelConsumerMessageSourceSpec |
consumerProperties(Consumer<PropertiesBuilder> consumerProperties) |
KafkaHighLevelConsumerMessageSourceSpec |
consumerProperties(java.util.Properties consumerProperties) |
protected org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?> |
doGet() |
java.util.Collection<java.lang.Object> |
getComponentsToRegister() |
_this, get, getId, id
public KafkaHighLevelConsumerMessageSourceSpec consumerProperties(java.util.Properties consumerProperties)
consumerProperties
- the Kafka High Level Consumer properties.public KafkaHighLevelConsumerMessageSourceSpec consumerProperties(Consumer<PropertiesBuilder> consumerProperties)
consumerProperties
- the PropertiesBuilder
Java 8 Lambda.public KafkaHighLevelConsumerMessageSourceSpec addConsumer(java.lang.String groupId, Consumer<KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec> consumerMetadataSpec)
KafkaHighLevelConsumerMessageSource
under provided groupId
.groupId
- the Consumer group id.consumerMetadataSpec
- the Consumer metadata Java 8 Lambda.KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec
public java.util.Collection<java.lang.Object> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration
protected org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?> doGet()
doGet
in class IntegrationComponentSpec<KafkaHighLevelConsumerMessageSourceSpec,org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?>>