Skip navigation links
C G H I J K L M O P S T 

C

createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties<KafkaProducerProperties>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 

G

getConsumerGroup() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.TopicInformation
 
getErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getErrorMessageStrategy() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
getPartitionInfos() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.TopicInformation
 

H

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

I

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

J

JaasConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.JaasConfigurationProperties
 
jaasInitializer() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 

K

kafka09AdminUtilsOperation() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 
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
 
KafkaBinderConfiguration.JaasConfigurationProperties - Class in org.springframework.cloud.stream.binder.kafka.config
 
KafkaBinderEnvironmentPostProcessor - Class in org.springframework.cloud.stream.binder.kafka
An EnvironmentPostProcessor that sets some common configuration properties (log config etc.,) for Kafka binder.
KafkaBinderEnvironmentPostProcessor() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
KafkaBinderHealthIndicator - Class in org.springframework.cloud.stream.binder.kafka
Health indicator for Kafka.
KafkaBinderHealthIndicator(KafkaMessageChannelBinder, ConsumerFactory<?, ?>) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator
 
kafkaBinderMetrics(KafkaMessageChannelBinder) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration
 
KafkaBinderMetrics - Class in org.springframework.cloud.stream.binder.kafka
Metrics for Kafka binder.
KafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties, ConsumerFactory<?, ?>) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics
 
KafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics
 
KafkaMessageChannelBinder - Class in org.springframework.cloud.stream.binder.kafka
A Binder that uses Kafka as the underlying middleware.
KafkaMessageChannelBinder(KafkaBinderConfigurationProperties, KafkaTopicProvisioner) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
KafkaMessageChannelBinder.TopicInformation - Class in org.springframework.cloud.stream.binder.kafka
 

L

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

M

metrics() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics
 

O

org.springframework.cloud.stream.binder.kafka - package org.springframework.cloud.stream.binder.kafka
 
org.springframework.cloud.stream.binder.kafka.config - package org.springframework.cloud.stream.binder.kafka.config
 

P

postProcessEnvironment(ConfigurableEnvironment, SpringApplication) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 

S

setExtendedBindingProperties(KafkaExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
setProducerListener(ProducerListener<byte[], byte[]>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
 
SPRING_KAFKA - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_CONSUMER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_CONSUMER_KEY_DESERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_CONSUMER_VALUE_DESERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_PRODUCER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_PRODUCER_KEY_SERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 
SPRING_KAFKA_PRODUCER_VALUE_SERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
 

T

TopicInformation(String, Collection<PartitionInfo>) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.TopicInformation
 
C G H I J K L M O P S T 
Skip navigation links

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