Uses of Class
org.springframework.integration.kafka.inbound.KafkaMessageSource

Packages that use KafkaMessageSource

Package	Description
org.springframework.integration.kafka.channel	Provides classes related to message channel implementations for Apache Kafka.
org.springframework.integration.kafka.dsl	Provides Spring Integration Java DSL Components support for Apache Kafka.

Uses of KafkaMessageSource in org.springframework.integration.kafka.channel

Constructors in org.springframework.integration.kafka.channel with parameters of type KafkaMessageSource

Modifier	Constructor	Description
	PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template, KafkaMessageSource<?,?> source)	Construct an instance with the provided parameters.

Uses of KafkaMessageSource in org.springframework.integration.kafka.dsl

Methods in org.springframework.integration.kafka.dsl with parameters of type KafkaMessageSource

Modifier and Type	Method	Description
static KafkaPollableChannelSpec	Kafka.pollableChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, KafkaMessageSource<?,?> source)	Create a spec for a pollable channel with the provided parameters.

Constructors in org.springframework.integration.kafka.dsl with parameters of type KafkaMessageSource

Modifier	Constructor	Description
protected	KafkaPollableChannelSpec(org.springframework.kafka.core.KafkaTemplate<?,?> template, KafkaMessageSource<?,?> source)