Index

A B C D E G I J K L M N O P R S U X
All Classes and Interfaces|All Packages|Constant Field Values

A

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

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

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

B

binderClientFactoryCustomizer(MeterRegistry) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfiguration.KafkaMicrometer

binderClientFactoryCustomizer(ConfigurableApplicationContext) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder.KafkaMicrometer

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

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

C

canConvertFrom(Message<?>, Class<?>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

ClientFactoryCustomizer - Interface in org.springframework.cloud.stream.binder.kafka.config

Called by the binder to customize the factories.

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

configure(ConsumerFactory<?, ?>) - Method in interface org.springframework.cloud.stream.binder.kafka.config.ClientFactoryCustomizer

configure(ProducerFactory<?, ?>) - Method in interface org.springframework.cloud.stream.binder.kafka.config.ClientFactoryCustomizer

configure(AbstractMessageListenerContainer<?, ?>, String, String) - Method in interface org.springframework.cloud.stream.binder.kafka.KafkaListenerContainerCustomizer

No-op override of ListenerContainerCustomizer.configure(Object, String, String).

configure(AbstractMessageListenerContainer<?, ?>, String, String) - Method in interface org.springframework.cloud.stream.binder.kafka.ListenerContainerWithDlqAndRetryCustomizer

API method for configuring the container that also gives access to the ExtendedConsumerProperties for the binding.

configure(AbstractMessageListenerContainer<?, ?>, String, String, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>, BackOff) - Method in interface org.springframework.cloud.stream.binder.kafka.ListenerContainerWithDlqAndRetryCustomizer

Configure the container.

configure(AbstractMessageListenerContainer<?, ?>, String, String, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>, BackOff, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in interface org.springframework.cloud.stream.binder.kafka.ListenerContainerWithDlqAndRetryCustomizer

API method for configuring the container that also gives access to the ExtendedConsumerProperties for the binding.

configure(AbstractMessageListenerContainer<?, ?>, String, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in interface org.springframework.cloud.stream.binder.kafka.KafkaListenerContainerCustomizer

Configure the Kafka listener container with access to extended consumer properties.

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

convertToInternal(Object, MessageHeaders, Object) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

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

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

createKafkaConsumerFactory(boolean, String, ExtendedConsumerProperties<KafkaConsumerProperties>, String, String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

createPolledConsumerResources(String, String, ConsumerDestination, 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

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

customizeProducerMessageHandler(MessageHandler, String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

D

DefaultMessageConverterHelper - Class in org.springframework.cloud.stream.binder.kafka.config

DefaultMessageConverterHelper() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.DefaultMessageConverterHelper

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

Returns an unmodifiable copy of ContainerProperties associated with the destination name which corresponds to a particular binding which could be accessed under 'containerProperties' key.

E

ExtendedBindingHandlerMappingsProviderConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

Configuration for extended binding metadata.

ExtendedBindingHandlerMappingsProviderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.ExtendedBindingHandlerMappingsProviderConfiguration

G

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

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

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

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

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

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

getPolledConsumerErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

getProducerFactory(String, ExtendedProducerProperties<KafkaProducerProperties>, String, String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

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

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

Return a reference to the binder's transaction manager's producer factory (if configured).

I

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

J

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

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

K

KafkaBinderConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

G© Kafka binder configuration class.

KafkaBinderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

KafkaBinderConfiguration.JaasConfigurationProperties - Class in org.springframework.cloud.stream.binder.kafka.config

Properties configuration for Jaas.

KafkaBinderConfiguration.KafkaBinderMetricsConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfiguration.KafkaBinderMetricsConfiguration.KafkaMicrometer - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder.KafkaMicrometer - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderHealth - Interface in org.springframework.cloud.stream.binder.kafka

Marker interface used for custom KafkaBinderHealth indicator implementations.

kafkaBinderHealthIndicator(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderHealthIndicatorConfiguration

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

KafkaBinderHealthIndicatorConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

Configuration class for Kafka binder health indicator beans.

KafkaBinderHealthIndicatorConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderHealthIndicatorConfiguration

kafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties, MeterRegistry) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfiguration

kafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties, ConfigurableApplicationContext) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder

KafkaBinderMetrics - Class in org.springframework.cloud.stream.binder.kafka

Metrics for Kafka binder.

KafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics

KafkaBinderMetrics(KafkaMessageChannelBinder, KafkaBinderConfigurationProperties, ConsumerFactory<?, ?>, MeterRegistry) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics

KafkaBinderMetricsConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfiguration

KafkaBinderMetricsConfigurationWithMultiBinder() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder

KafkaBinderRuntimeHints - Class in org.springframework.cloud.stream.binder.kafka.aot

RuntimeHintsRegistrar for the Kafka binder in Spring Cloud Stream.

KafkaBinderRuntimeHints() - Constructor for class org.springframework.cloud.stream.binder.kafka.aot.KafkaBinderRuntimeHints

KafkaBindingRebalanceListener - Interface in org.springframework.cloud.stream.binder.kafka

A rebalance listener that provides access to the binding name consumer object.

KafkaExpressionEvaluatingInterceptor - Class in org.springframework.cloud.stream.binder.kafka

Interceptor to evaluate expressions for outbound messages before serialization.

KafkaExpressionEvaluatingInterceptor(Expression, EvaluationContext) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaExpressionEvaluatingInterceptor

Construct an instance with the provided expressions and evaluation context.

kafkaExtendedPropertiesDefaultMappingsProvider() - Method in class org.springframework.cloud.stream.binder.kafka.config.ExtendedBindingHandlerMappingsProviderConfiguration

KafkaListenerContainerCustomizer - Interface in org.springframework.cloud.stream.binder.kafka

Extension of ListenerContainerCustomizer specific to Kafka binder.

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(KafkaBinderConfigurationProperties, KafkaTopicProvisioner, ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>>, KafkaBindingRebalanceListener) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

KafkaMessageChannelBinder(KafkaBinderConfigurationProperties, KafkaTopicProvisioner, ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>>, MessageSourceCustomizer<KafkaMessageSource<?, ?>>, KafkaBindingRebalanceListener, DlqPartitionFunction, DlqDestinationResolver) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

KafkaMessageChannelBinder.NullObservationRegistry - Class in org.springframework.cloud.stream.binder.kafka

kafkaMessageConverterHelper() - Method in class org.springframework.cloud.stream.binder.kafka.config.MessageConverterHelperConfiguration

KafkaMicrometer() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfiguration.KafkaMicrometer

KafkaMicrometer() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.KafkaBinderMetricsConfigurationWithMultiBinder.KafkaMicrometer

KafkaNullConverter - Class in org.springframework.cloud.stream.binder.kafka

A MessageConverter that supports KafkaNull payloads.

KafkaNullConverter() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

L

ListenerContainerWithDlqAndRetryCustomizer - Interface in org.springframework.cloud.stream.binder.kafka

An extension of ListenerContainerCustomizer that provides access to dead letter metadata.

M

MESSAGE_KEY_HEADER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaExpressionEvaluatingInterceptor

Name for the evaluated message key header.

MessageConverterHelperConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

MessageConverterHelperConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.MessageConverterHelperConfiguration

N

NullObservationRegistry() - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.NullObservationRegistry

O

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

OFFSET_LAG_METRIC_NAME - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics

Offset lag micrometer metric name.

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

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

onPartitionsAssigned(String, Consumer<?, ?>, Collection<TopicPartition>, boolean) - Method in interface org.springframework.cloud.stream.binder.kafka.KafkaBindingRebalanceListener

Invoked when partitions are initially assigned or after a rebalance.

onPartitionsRevokedAfterCommit(String, Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.cloud.stream.binder.kafka.KafkaBindingRebalanceListener

Invoked by the container after any pending offsets are committed.

onPartitionsRevokedBeforeCommit(String, Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.cloud.stream.binder.kafka.KafkaBindingRebalanceListener

Invoked by the container before any pending offsets are committed.

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

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

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

P

postProcessBatchMessageOnFailure(Message<?>, int) - Method in class org.springframework.cloud.stream.binder.kafka.config.DefaultMessageConverterHelper

postProcessOutputChannel(MessageChannel, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

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

preSend(Message<?>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExpressionEvaluatingInterceptor

R

registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.cloud.stream.binder.kafka.aot.KafkaBinderRuntimeHints

retryAndDlqInBinding(String, String) - Method in interface org.springframework.cloud.stream.binder.kafka.ListenerContainerWithDlqAndRetryCustomizer

Return false to move retries and DLQ from the binding to a customized error handler using the retry metadata and/or a DeadLetterPublishingRecoverer when configured via ListenerContainerWithDlqAndRetryCustomizer.configure(AbstractMessageListenerContainer, String, String, BiFunction, BackOff).

S

setCurrentObservationScope(Observation.Scope) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.NullObservationRegistry

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

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

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

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

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

setupRebalanceListener(ExtendedConsumerProperties<KafkaConsumerProperties>, ContainerProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

shouldFailIfCantConvert(Message<?>) - Method in class org.springframework.cloud.stream.binder.kafka.config.DefaultMessageConverterHelper

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

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

supports(Class<?>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

supportsMimeType(MessageHeaders) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaNullConverter

U

useNativeEncoding(ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

X

X_EXCEPTION_FQCN - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-exception-fqcn.

X_EXCEPTION_MESSAGE - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-exception-message.

X_EXCEPTION_STACKTRACE - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-exception-stacktrace.

X_ORIGINAL_OFFSET - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-original-offset.

X_ORIGINAL_PARTITION - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-original-partition.

X_ORIGINAL_TIMESTAMP - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-original-timestamp.

X_ORIGINAL_TIMESTAMP_TYPE - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-original-timestamp-type.

X_ORIGINAL_TOPIC - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Kafka header for x-original-topic.

A B C D E G I J K L M N O P R S U X
All Classes and Interfaces|All Packages|Constant Field Values