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.