public final class Kafka
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static <K,V,A extends KafkaMessageDrivenChannelAdapterSpec<K,V,A>> |
messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
Create an initial
KafkaMessageDrivenChannelAdapterSpec . |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.listener.config.ContainerProperties containerProperties)
|
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
java.util.regex.Pattern topicPattern)
|
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
java.lang.String... topics)
|
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.support.TopicPartitionInitialOffset... topicPartitions)
|
static <K,V> KafkaProducerMessageHandlerSpec<K,V> |
outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
Create an initial
KafkaProducerMessageHandlerSpec . |
static <K,V> KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)
Create an initial
KafkaProducerMessageHandlerSpec with ProducerFactory. |
public static <K,V> KafkaProducerMessageHandlerSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
KafkaProducerMessageHandlerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.kafkaTemplate
- the KafkaTemplate
to usepublic static <K,V> KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)
KafkaProducerMessageHandlerSpec
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 KafkaMessageDrivenChannelAdapterSpec<K,V,A>> KafkaMessageDrivenChannelAdapterSpec<K,V,A> messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
KafkaMessageDrivenChannelAdapterSpec
.K
- the Kafka message key type.V
- the Kafka message value type.A
- the KafkaMessageDrivenChannelAdapterSpec
extension type.listenerContainer
- the AbstractMessageListenerContainer
.public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.config.ContainerProperties containerProperties)
KafkaMessageDrivenChannelAdapterSpec.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> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.support.TopicPartitionInitialOffset... topicPartitions)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topicPartitions
- the TopicPartition
vararg.public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, java.lang.String... topics)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topics
- the topics vararg.public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, java.util.regex.Pattern topicPattern)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.K
- the Kafka message key type.V
- the Kafka message value type.consumerFactory
- the ConsumerFactory
.topicPattern
- the topicPattern vararg.