Skip navigation links
C D G H I K O S V 

C

createConsumerDestinationIfNecessary(String, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
createConsumerEndpoint(String, String, Collection<PartitionInfo>, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
createProducerDestinationIfNecessary(String, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
createProducerMessageHandler(String, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 

D

destroy() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 

G

getAutoCommitOnError() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
getBatchTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
getBindings() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties
 
getBrokers() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getBufferSize() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
getCompressionType() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
getConsumer() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties
 
getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties
 
getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties
 
getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getFetchSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getHeaders() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getKafkaConnectionString() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getMaxWait() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getMinPartitionCount() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getOffsetUpdateCount() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getOffsetUpdateShutdownTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getOffsetUpdateTimeWindow() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getProducer() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties
 
getQueueSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getRecoveryInterval() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
getReferencePoint() - Method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset
 
getReplicationFactor() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getRequiredAcks() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getSocketBufferSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getStartOffset() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
getZkConnectionString() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getZkConnectionTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getZkNodes() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
getZkSessionTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 

H

health() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator
 

I

isAutoAddPartitions() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
isAutoCommitOffset() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
isAutoCreateTopics() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
isAutoRebalanceEnabled() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
isEnableDlq() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
isResetOffsets() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
isSync() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 

K

KafkaBinderConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config
 
KafkaBinderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 
KafkaBinderConfigurationProperties - Class in org.springframework.cloud.stream.binder.kafka.config
 
KafkaBinderConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
KafkaBinderHealthIndicator - Class in org.springframework.cloud.stream.binder.kafka
Health indicator for Kafka.
KafkaBinderHealthIndicator(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator
 
KafkaBindingProperties - Class in org.springframework.cloud.stream.binder.kafka
 
KafkaBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties
 
KafkaConsumerProperties - Class in org.springframework.cloud.stream.binder.kafka
 
KafkaConsumerProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
KafkaConsumerProperties.StartOffset - Enum in org.springframework.cloud.stream.binder.kafka
 
KafkaExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.kafka
 
KafkaExtendedBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties
 
KafkaMessageChannelBinder - Class in org.springframework.cloud.stream.binder.kafka
A Binder that uses Kafka as the underlying middleware.
KafkaMessageChannelBinder(KafkaBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
KafkaProducerProperties - Class in org.springframework.cloud.stream.binder.kafka
 
KafkaProducerProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
KafkaProducerProperties.CompressionType - Enum in org.springframework.cloud.stream.binder.kafka
 
KafkaTopicUtils - Class in org.springframework.cloud.stream.binder.kafka
 

O

onInit() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
org.springframework.cloud.stream.binder.kafka - package org.springframework.cloud.stream.binder.kafka
This package contains an implementation of the Binder for Kafka.
org.springframework.cloud.stream.binder.kafka.config - package org.springframework.cloud.stream.binder.kafka.config
 

S

setAutoAddPartitions(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setAutoCommitOffset(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setAutoCommitOnError(Boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setAutoCreateTopics(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setAutoRebalanceEnabled(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setBatchTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
setBindings(Map<String, KafkaBindingProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties
 
setBrokers(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setBufferSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
setCompressionType(KafkaProducerProperties.CompressionType) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
setConsumer(KafkaConsumerProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties
 
setDefaultBrokerPort(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setDefaultZkPort(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setEnableDlq(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setExtendedBindingProperties(KafkaExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
setFetchSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setHeaders(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setMaxWait(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setMetadataRetryOperations(RetryOperations) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
Retry configuration for operations such as validating topic creation
setMinPartitionCount(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setOffsetUpdateCount(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setOffsetUpdateShutdownTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setOffsetUpdateTimeWindow(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setProducer(KafkaProducerProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties
 
setProducerListener(ProducerListener<byte[], byte[]>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
setQueueSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setRecoveryInterval(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setReplicationFactor(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setRequiredAcks(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setResetOffsets(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setSocketBufferSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setStartOffset(KafkaConsumerProperties.StartOffset) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties
 
setSync(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties
 
setZkConnectionTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setZkNodes(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 
setZkSessionTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties
 

V

validateTopicName(String) - Static method in class org.springframework.cloud.stream.binder.kafka.KafkaTopicUtils
Allowed chars are ASCII alphanumerics, '.', '_' and '-'.
valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties.CompressionType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties.CompressionType
Returns an array containing the constants of this enum type, in the order they are declared.
C D G H I K O S V 
Skip navigation links

Copyright © 2016 Pivotal Software, Inc.. All rights reserved.