Package | Description |
---|---|
org.springframework.cloud.stream.binder.kafka |
This package contains an implementation of the
Binder for Kafka. |
Modifier and Type | Method and Description |
---|---|
KafkaConsumerProperties |
KafkaBindingProperties.getConsumer() |
KafkaConsumerProperties |
KafkaMessageChannelBinder.getExtendedConsumerProperties(String channelName) |
KafkaConsumerProperties |
KafkaExtendedBindingProperties.getExtendedConsumerProperties(String channelName) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaBindingProperties.setConsumer(KafkaConsumerProperties consumer) |
Modifier and Type | Method and Description |
---|---|
protected Collection<org.apache.kafka.common.PartitionInfo> |
KafkaMessageChannelBinder.createConsumerDestinationIfNecessary(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> properties) |
protected org.springframework.integration.core.MessageProducer |
KafkaMessageChannelBinder.createConsumerEndpoint(String name,
String group,
Collection<org.apache.kafka.common.PartitionInfo> destination,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KafkaConsumerProperties> properties) |
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.