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