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.