Skip navigation links
A C D E G H I K L O P S V 

A

AdminUtilsOperation - Interface in org.springframework.cloud.stream.binder.kafka.admin
API around AdminUtils to support various versions of Kafka brokers.

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
 

E

errorCodeFromTopicMetadata(String, ZkUtils) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation
Invoke AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)
errorCodeFromTopicMetadata(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation
 
errorCodeFromTopicMetadata(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation
 

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

invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation
Invoke AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)
invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation
 
invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation
 
invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation
Inovke AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)
invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation
 
invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation
 
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

Kafka09AdminUtilsOperation - Class in org.springframework.cloud.stream.binder.kafka.admin
 
Kafka09AdminUtilsOperation() - Constructor for class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation
 
kafka09AdminUtilsOperation() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 
Kafka10AdminUtilsOperation - Class in org.springframework.cloud.stream.binder.kafka.admin
 
Kafka10AdminUtilsOperation() - Constructor for class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation
 
kafka10AdminUtilsOperation() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 
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
 

L

logger - Variable in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 

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.admin - package org.springframework.cloud.stream.binder.kafka.admin
 
org.springframework.cloud.stream.binder.kafka.config - package org.springframework.cloud.stream.binder.kafka.config
 

P

partitionSize(String, ZkUtils) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation
Find partition size from Kafka broker using AdminUtils
partitionSize(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation
 
partitionSize(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation
 

S

setAdminUtilsOperation(AdminUtilsOperation) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
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.
A C D E G H I K L O P S V 
Skip navigation links

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