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, idpublic 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.ConsumerMetadataSpecpublic java.util.Collection<java.lang.Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistrationprotected org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?> doGet()
doGet in class IntegrationComponentSpec<KafkaHighLevelConsumerMessageSourceSpec,org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource<?,?>>