public abstract class Kafka
extends java.lang.Object
Constructor and Description |
---|
Kafka() |
Modifier and Type | Method and Description |
---|---|
static KafkaHighLevelConsumerMessageSourceSpec |
inboundChannelAdapter(org.springframework.integration.kafka.support.ZookeeperConnect zookeeperConnect)
Create an initial
KafkaHighLevelConsumerMessageSourceSpec . |
static KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec |
messageDriverChannelAdapter(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory,
org.springframework.integration.kafka.core.Partition... partitions)
|
static KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec |
messageDriverChannelAdapter(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory,
java.lang.String... topics)
|
static KafkaMessageDrivenChannelAdapterSpec |
messageDriverChannelAdapter(org.springframework.integration.kafka.listener.KafkaMessageListenerContainer messageListenerContainer)
Create an initial
KafkaMessageDrivenChannelAdapterSpec . |
static KafkaProducerMessageHandlerSpec |
outboundChannelAdapter()
Create an initial
KafkaProducerMessageHandlerSpec . |
static KafkaProducerMessageHandlerSpec |
outboundChannelAdapter(Consumer<PropertiesBuilder> producerProperties)
Create an initial
KafkaProducerMessageHandlerSpec with Kafka Producer properties. |
static KafkaProducerMessageHandlerSpec |
outboundChannelAdapter(java.util.Properties producerProperties)
Create an initial
KafkaProducerMessageHandlerSpec with Kafka Producer properties. |
public static KafkaHighLevelConsumerMessageSourceSpec inboundChannelAdapter(org.springframework.integration.kafka.support.ZookeeperConnect zookeeperConnect)
KafkaHighLevelConsumerMessageSourceSpec
.zookeeperConnect
- the zookeeperConnect.public static KafkaProducerMessageHandlerSpec outboundChannelAdapter()
KafkaProducerMessageHandlerSpec
.public static KafkaProducerMessageHandlerSpec outboundChannelAdapter(Consumer<PropertiesBuilder> producerProperties)
KafkaProducerMessageHandlerSpec
with Kafka Producer properties.producerProperties
- the PropertiesBuilder
Java 8 Lambda.public static KafkaProducerMessageHandlerSpec outboundChannelAdapter(java.util.Properties producerProperties)
KafkaProducerMessageHandlerSpec
with Kafka Producer properties.producerProperties
- the producerProperties.public static KafkaMessageDrivenChannelAdapterSpec messageDriverChannelAdapter(org.springframework.integration.kafka.listener.KafkaMessageListenerContainer messageListenerContainer)
KafkaMessageDrivenChannelAdapterSpec
.messageListenerContainer
- the KafkaMessageListenerContainer
.public static KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec messageDriverChannelAdapter(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory, org.springframework.integration.kafka.core.Partition... partitions)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.connectionFactory
- the ConnectionFactory
.partitions
- the Partition
vararg.public static KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec messageDriverChannelAdapter(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory, java.lang.String... topics)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
.connectionFactory
- the ConnectionFactory
.topics
- the Kafka topic name vararg.