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,S extends KafkaInboundGatewaySpec<K,V,R,S>> |
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.config.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,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. |
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,S extends KafkaOutboundGatewaySpec<K,V,R,S>> |
outboundGateway(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> kafkaTemplate)
Create an initial
KafkaProducerMessageHandlerSpec. |
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> 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,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.public static <K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> KafkaOutboundGatewaySpec<K,V,R,S> 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).S - the KafkaOutboundGatewaySpec extension type.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,S extends KafkaInboundGatewaySpec<K,V,R,S>> KafkaInboundGatewaySpec<K,V,R,S> inboundGateway(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> container, org.springframework.kafka.core.KafkaTemplate<K,R> template)
KafkaInboundGatewaySpec with the provided container and
template.K - the Kafka message key type.V - the Kafka message value type (request).R - the Kafka message value type (reply).S - the KafkaInboundGatewaySpec extension type.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.config.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.