public class KafkaMessageChannelBinder extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties>,KafkaTopicProvisioner> implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,KafkaConsumerProperties,KafkaProducerProperties>
Binder
that uses Kafka as the underlying middleware.Modifier and Type | Class and Description |
---|---|
static class |
KafkaMessageChannelBinder.TopicInformation |
Constructor and Description |
---|
KafkaMessageChannelBinder(KafkaBinderConfigurationProperties configurationProperties,
KafkaTopicProvisioner provisioningProvider) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.integration.core.MessageProducer |
createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties) |
protected org.springframework.messaging.MessageHandler |
createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
protected org.springframework.messaging.MessageHandler |
getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties) |
protected org.springframework.integration.support.ErrorMessageStrategy |
getErrorMessageStrategy() |
KafkaConsumerProperties |
getExtendedConsumerProperties(String channelName) |
KafkaProducerProperties |
getExtendedProducerProperties(String channelName) |
void |
setExtendedBindingProperties(KafkaExtendedBindingProperties extendedBindingProperties) |
void |
setProducerListener(org.springframework.kafka.support.ProducerListener<byte[],byte[]> producerListener) |
afterUnbindConsumer, afterUnbindProducer, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandlerName, getErrorRecovererName, registerErrorInfrastructure
afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, deserializePayloadIfNecessary, deserializePayloadIfNecessary, getApplicationContext, getBeanFactory, groupedName, onInit, serializePayloadIfNecessary, serializePayloadIfNecessary, setApplicationContext, setCodec, setIntegrationEvaluationContext
public KafkaMessageChannelBinder(KafkaBinderConfigurationProperties configurationProperties, KafkaTopicProvisioner provisioningProvider)
public void setExtendedBindingProperties(KafkaExtendedBindingProperties extendedBindingProperties)
public void setProducerListener(org.springframework.kafka.support.ProducerListener<byte[],byte[]> producerListener)
public KafkaConsumerProperties getExtendedConsumerProperties(String channelName)
getExtendedConsumerProperties
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KafkaConsumerProperties,KafkaProducerProperties>
public KafkaProducerProperties getExtendedProducerProperties(String channelName)
getExtendedProducerProperties
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KafkaConsumerProperties,KafkaProducerProperties>
protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel) throws Exception
createProducerMessageHandler
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties>,KafkaTopicProvisioner>
Exception
protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties)
createConsumerEndpoint
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties>,KafkaTopicProvisioner>
protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()
getErrorMessageStrategy
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties>,KafkaTopicProvisioner>
protected org.springframework.messaging.MessageHandler getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties)
getErrorMessageHandler
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KafkaProducerProperties>,KafkaTopicProvisioner>
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.