public abstract class Kafka09
extends java.lang.Object
Constructor and Description |
---|
Kafka09() |
Modifier and Type | Method and Description |
---|---|
static <K,V,A extends Kafka09MessageDrivenChannelAdapterSpec<K,V,A>> |
messageDriverChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
Create an initial
Kafka09MessageDrivenChannelAdapterSpec . |
static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.listener.config.ContainerProperties containerProperties)
|
static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
java.util.regex.Pattern topicPattern)
|
static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
java.lang.String... topics)
|
static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.support.TopicPartitionInitialOffset... topicPartitions)
|
static <K,V> Kafka09ProducerMessageHandlerSpec<K,V> |
outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
Create an initial
Kafka09ProducerMessageHandlerSpec . |
static <K,V> Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)
Create an initial
Kafka09ProducerMessageHandlerSpec with ProducerFactory. |
public static <K,V> Kafka09ProducerMessageHandlerSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
Kafka09ProducerMessageHandlerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.kafkaTemplate
- the KafkaTemplate
to usepublic static <K,V> Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)
Kafka09ProducerMessageHandlerSpec
with ProducerFactory.K
- the Kafka message key type.V
- the Kafka message value type.producerFactory
- the ProducerFactory
Java 8 Lambda.public static <K,V,A extends Kafka09MessageDrivenChannelAdapterSpec<K,V,A>> Kafka09MessageDrivenChannelAdapterSpec<K,V,A> messageDriverChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
Kafka09MessageDrivenChannelAdapterSpec
.K
- the Kafka message key type.V
- the Kafka message value type.A
- the Kafka09MessageDrivenChannelAdapterSpec
extension type.listenerContainer
- the AbstractMessageListenerContainer
.public static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.config.ContainerProperties containerProperties)
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.containerProperties
- the ContainerProperties
to use.public static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.support.TopicPartitionInitialOffset... topicPartitions)
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topicPartitions
- the TopicPartition
vararg.public static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, java.lang.String... topics)
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topics
- the topics vararg.public static <K,V> Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDriverChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, java.util.regex.Pattern topicPattern)
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topicPattern
- the topicPattern vararg.