public final class Kafka
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaInboundChannelAdapterSpec<K,V> |
inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory,
java.lang.String... topics)
Create an initial
KafkaInboundChannelAdapterSpec with the consumer factory and
topics with a custom ack callback factory. |
static <K,V> KafkaInboundChannelAdapterSpec<K,V> |
inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
java.lang.String... topics)
Create an initial
KafkaInboundChannelAdapterSpec with the consumer factory and
topics. |
static <K,V,R> KafkaInboundGatewaySpec<K,V,R,?> |
inboundGateway(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> container,
org.springframework.kafka.core.KafkaTemplate<K,R> template)
Create an initial
KafkaInboundGatewaySpec with the provided container and
template. |
static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> |
inboundGateway(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.listener.ContainerProperties containerProperties,
org.springframework.kafka.core.ProducerFactory<K,R> producerFactory)
Create an initial
KafkaInboundGatewaySpec with the provided consumer factory,
container properties and producer factory. |
static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> |
inboundGateway(KafkaMessageListenerContainerSpec<K,V> containerSpec,
KafkaTemplateSpec<K,R> templateSpec)
Create an initial
KafkaInboundGatewaySpec with the provided container and
template specs. |
static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> |
messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
Create an initial
KafkaMessageDrivenChannelAdapterSpec. |
static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> |
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.ContainerProperties containerProperties)
|
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> |
messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory,
org.springframework.kafka.listener.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> 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. |
static <K,V,R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> |
outboundGateway(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory,
org.springframework.kafka.listener.GenericMessageListenerContainer<K,R> replyContainer)
Create an initial
KafkaProducerMessageHandlerSpec with ProducerFactory. |
static <K,V,R> KafkaOutboundGatewaySpec<K,V,R,?> |
outboundGateway(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> kafkaTemplate)
Create an initial
KafkaProducerMessageHandlerSpec. |
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> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, java.lang.String... topics)
KafkaInboundChannelAdapterSpec with the consumer factory and
topics.K - the Kafka message key type.V - the Kafka message value type.consumerFactory - the consumer factory.topics - the topic(s).public static <K,V> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, java.lang.String... topics)
KafkaInboundChannelAdapterSpec with the consumer factory and
topics with a custom ack callback factory.K - the Kafka message key type.V - the Kafka message value type.consumerFactory - the consumer factory.ackCallbackFactory - the callback factory.topics - the topic(s).public static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
KafkaMessageDrivenChannelAdapterSpec. If the listener
container is not already a bean it will be registered in the application context.
If the adapter spec has an id, the bean name will be that id appended with
'.container'. Otherwise, the bean name will be generated from the container class
name.K - the Kafka message key type.V - the Kafka message value type.listenerContainer - the AbstractMessageListenerContainer.public static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode)
KafkaMessageDrivenChannelAdapterSpec. If the listener
container is not already a bean it will be registered in the application context.
If the adapter spec has an id, the bean name will be that id appended with
'.container'. Otherwise, the bean name will be generated from the container class
name.K - the Kafka message key type.V - the Kafka message value 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.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.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.public static <K,V,R> KafkaOutboundGatewaySpec<K,V,R,?> outboundGateway(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> kafkaTemplate)
KafkaProducerMessageHandlerSpec.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).kafkaTemplate - the ReplyingKafkaTemplate to usepublic static <K,V,R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> outboundGateway(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory, org.springframework.kafka.listener.GenericMessageListenerContainer<K,R> replyContainer)
KafkaProducerMessageHandlerSpec with ProducerFactory.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).producerFactory - the ProducerFactory Java 8 Lambda.replyContainer - a listener container for replies.public static <K,V,R> KafkaInboundGatewaySpec<K,V,R,?> inboundGateway(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> container, org.springframework.kafka.core.KafkaTemplate<K,R> template)
KafkaInboundGatewaySpec with the provided container and
template. If the listener container is not already a bean it will be registered in
the application context. If the adapter spec has an id, the bean name will
be that id appended with '.container'. Otherwise, the bean name will be generated
from the container class name.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).container - the container.template - the template.public static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> inboundGateway(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, org.springframework.kafka.core.ProducerFactory<K,R> producerFactory)
KafkaInboundGatewaySpec with the provided consumer factory,
container properties and producer factory.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).consumerFactory - the consumer factory.containerProperties - the container properties.producerFactory - the producer factory.public static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> inboundGateway(KafkaMessageListenerContainerSpec<K,V> containerSpec, KafkaTemplateSpec<K,R> templateSpec)
KafkaInboundGatewaySpec with the provided container and
template specs.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).containerSpec - the container spec.templateSpec - the template spec.