See: Description
Class | Description |
---|---|
Kafka |
Factory class for Kafka components.
|
Kafka09 |
Factory class for Kafka-0.9 components.
|
Kafka09MessageDrivenChannelAdapter<K,V> |
The copy of
org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
from Spring Integration Kafka 2.0, since we can't upgrade to spring-integration-kafka-2.0 . |
Kafka09MessageDrivenChannelAdapterSpec<K,V,S extends Kafka09MessageDrivenChannelAdapterSpec<K,V,S>> |
A
MessageProducerSpec implementation for the Kafka09MessageDrivenChannelAdapter . |
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
A
ConcurrentMessageListenerContainer configuration Kafka09MessageDrivenChannelAdapterSpec
extension. |
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> |
A helper class in the Builder pattern style to delegate options to the
ConcurrentMessageListenerContainer . |
Kafka09ProducerMessageHandler<K,V> |
The copy of
org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
from Spring Integration Kafka 2.0, since we can't upgrade to spring-integration-kafka-2.0 . |
Kafka09ProducerMessageHandlerSpec<K,V> |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler . |
Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
A
KafkaTemplate -based Kafka09ProducerMessageHandlerSpec extension. |
KafkaHighLevelConsumerMessageSourceSpec |
A
MessageSourceSpec
for KafkaHighLevelConsumerMessageSource . |
KafkaMessageDrivenChannelAdapterSpec<S extends KafkaMessageDrivenChannelAdapterSpec<S>> |
A
MessageProducerSpec implementation for the KafkaMessageDrivenChannelAdapter . |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec |
A
KafkaMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec
extension. |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec |
A helper class in the Builder pattern style to delegate options to the
KafkaMessageListenerContainer . |
KafkaProducerMessageHandlerSpec |
A
MessageHandlerSpec implementation for the KafkaProducerMessageHandler . |