Index

A B C D E F G H I J K L M N O P R S T U V W Z 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

C

CASE_SENSITIVE - Static variable in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
Set to false to make topic pattern matching case-insensitive.
categories() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels
Category names representing Log4j or Logback categories to change.
categories(String...) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
 
ChainedKafkaTransactionManager<K,V> - Class in org.springframework.kafka.transaction
Deprecated.
Refer to the ChainedTransactionManager javadocs.
ChainedKafkaTransactionManager(PlatformTransactionManager...) - Constructor for class org.springframework.kafka.transaction.ChainedKafkaTransactionManager
Deprecated.
Construct an instance with the provided PlatformTransactionManagers.
checkBootstrap(Map<String, Object>) - Method in class org.springframework.kafka.core.KafkaResourceFactory
Enhance the properties by calling the KafkaResourceFactory.setBootstrapServersSupplier(Supplier) and replace the bootstrap servers properties.
checkDeserialization(ConsumerRecord<?, ?>, LogAccessor) - Static method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
Return a DeserializationException if either the key or value failed deserialization; null otherwise.
checkDeserializer(ConsumerFactory<K, V>, Properties, boolean, ClassLoader) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils
Determine whether the key or value deserializer is an instance of ErrorHandlingDeserializer.
checkForErrors(ConsumerRecord<K, R>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
Check for errors in a reply.
checkGroupId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
 
checkTopics() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
 
childStopped(MessageListenerContainer, ConsumerStoppedEvent.Reason) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
 
childStopped(MessageListenerContainer, ConsumerStoppedEvent.Reason) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
 
childStopped(MessageListenerContainer, ConsumerStoppedEvent.Reason) - Method in interface org.springframework.kafka.listener.MessageListenerContainer
Notify a parent container that a child container has stopped.
classes() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels
Classes representing Log4j categories to change.
ClassMapper - Interface in org.springframework.kafka.support.mapping
Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
CleanupConfig - Class in org.springframework.kafka.core
Specifies time of KafkaStreams.cleanUp() execution.
CleanupConfig() - Constructor for class org.springframework.kafka.core.CleanupConfig
 
CleanupConfig(boolean, boolean) - Constructor for class org.springframework.kafka.core.CleanupConfig
 
cleanupOnStart() - Method in class org.springframework.kafka.core.CleanupConfig
 
cleanupOnStop() - Method in class org.springframework.kafka.core.CleanupConfig
 
clearConsumerGroupId() - Static method in class org.springframework.kafka.support.KafkaUtils
Clear the group id for the consumer bound to this thread.
clearThreadState() - Method in interface org.springframework.kafka.listener.AfterRollbackProcessor
Optional method to clear thread state; will be called just before a consumer thread terminates.
clearThreadState() - Method in class org.springframework.kafka.listener.CommonDelegatingErrorHandler
 
clearThreadState() - Method in interface org.springframework.kafka.listener.CommonErrorHandler
Optional method to clear thread state; will be called just before a consumer thread terminates.
clearThreadState() - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
 
clearThreadState() - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
 
clearThreadState() - Method in class org.springframework.kafka.listener.FailedRecordProcessor
 
clearThreadState() - Method in interface org.springframework.kafka.listener.GenericErrorHandler
Deprecated.
Optional method to clear thread state; will be called just before a consumer thread terminates.
clearThreadState(Consumer<?, ?>) - Method in class org.springframework.kafka.listener.CompositeBatchInterceptor
 
clearThreadState(Consumer<?, ?>) - Method in class org.springframework.kafka.listener.CompositeRecordInterceptor
 
clearThreadState(Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ThreadStateProcessor
Call to clear thread-bound resources which were set up in ThreadStateProcessor.setupThreadState(Consumer).
clientIdPrefix() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
When provided, overrides the client id property in the consumer factory configuration.
close() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
 
close() - Method in class org.springframework.kafka.core.KafkaResourceHolder
 
close() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
 
close() - Method in class org.springframework.kafka.streams.HeaderEnricher
Deprecated.
 
close() - Method in class org.springframework.kafka.streams.HeaderEnricherProcessor
 
close() - Method in class org.springframework.kafka.streams.messaging.MessagingProcessor
 
close() - Method in class org.springframework.kafka.streams.messaging.MessagingTransformer
Deprecated.
 
close() - Method in class org.springframework.kafka.support.CompositeProducerInterceptor
 
close() - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
 
close() - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
 
close() - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
 
close() - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
 
close() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
 
close() - Method in class org.springframework.kafka.support.serializer.JsonSerde
 
close() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
 
close() - Method in class org.springframework.kafka.support.serializer.RetryingDeserializer
 
close() - Method in class org.springframework.kafka.support.serializer.StringOrBytesSerializer
 
close() - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
 
close(Duration) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
 
closeProducer(Producer<K, V>, boolean) - Method in class org.springframework.kafka.core.KafkaTemplate
 
closeProducerFor(String) - Method in interface org.springframework.kafka.core.ProducerFactory
Deprecated, for removal: This API element is subject to removal in a future version.
- no longer needed.
closeThreadBoundProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
When using DefaultKafkaProducerFactory.setProducerPerThread(boolean) (true), call this method to close and release this thread's producer.
closeThreadBoundProducer() - Method in interface org.springframework.kafka.core.ProducerFactory
If the factory implementation uses thread-bound producers, call this method to close and release this thread's producer.
clusterId() - Method in class org.springframework.kafka.core.KafkaAdmin
 
clusterId() - Method in interface org.springframework.kafka.core.KafkaAdminOperations
Return the cluster id, if available.
commit() - Method in class org.springframework.kafka.core.KafkaResourceHolder
 
committed(Set<TopicPartition>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
 
commitTransaction() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
 
CommonContainerStoppingErrorHandler - Class in org.springframework.kafka.listener
A CommonErrorHandler that stops the container when an error occurs.
CommonContainerStoppingErrorHandler() - Constructor for class org.springframework.kafka.listener.CommonContainerStoppingErrorHandler
Construct an instance with a default SimpleAsyncTaskExecutor.
CommonContainerStoppingErrorHandler(Executor) - Constructor for class org.springframework.kafka.listener.CommonContainerStoppingErrorHandler
Construct an instance with the provided Executor.
CommonDelegatingErrorHandler - Class in org.springframework.kafka.listener
An error handler that delegates to different error handlers, depending on the exception type.
CommonDelegatingErrorHandler(CommonErrorHandler) - Constructor for class org.springframework.kafka.listener.CommonDelegatingErrorHandler
Construct an instance with a default error handler that will be invoked if the exception has no matches.
CommonErrorHandler - Interface in org.springframework.kafka.listener
Replacement for ErrorHandler and BatchErrorHandler and their sub-interfaces.
commonHeaders(Acknowledgment, Consumer<?, ?>, Map<String, Object>, Object, Object, Object, Object, Object, Object) - Method in interface org.springframework.kafka.support.converter.MessageConverter
Set up the common headers.
CommonLoggingErrorHandler - Class in org.springframework.kafka.listener
The CommonErrorHandler implementation for logging exceptions.
CommonLoggingErrorHandler() - Constructor for class org.springframework.kafka.listener.CommonLoggingErrorHandler
 
CommonMixedErrorHandler - Class in org.springframework.kafka.listener
A CommonErrorHandler that delegates to different CommonErrorHandlers for record and batch listeners.
CommonMixedErrorHandler(CommonErrorHandler, CommonErrorHandler) - Constructor for class org.springframework.kafka.listener.CommonMixedErrorHandler
Construct an instance with the provided delegate CommonErrorHandlers.
compact() - Method in class org.springframework.kafka.config.TopicBuilder
Set the TopicConfig.CLEANUP_POLICY_CONFIG to TopicConfig.CLEANUP_POLICY_COMPACT.
CompositeBatchInterceptor<K,V> - Class in org.springframework.kafka.listener
A BatchInterceptor that delegates to one or more BatchInterceptors in order.
CompositeBatchInterceptor(BatchInterceptor<K, V>...) - Constructor for class org.springframework.kafka.listener.CompositeBatchInterceptor
Construct an instance with the provided delegates.
CompositeKafkaStreamsCustomizer - Class in org.springframework.kafka.config
Composite KafkaStreamsCustomizer customizes KafkaStreams by delegating to a list of provided KafkaStreamsCustomizer.
CompositeKafkaStreamsCustomizer() - Constructor for class org.springframework.kafka.config.CompositeKafkaStreamsCustomizer
 
CompositeKafkaStreamsCustomizer(List<KafkaStreamsCustomizer>) - Constructor for class org.springframework.kafka.config.CompositeKafkaStreamsCustomizer
 
CompositeKafkaStreamsInfrastructureCustomizer - Class in org.springframework.kafka.config
Composite KafkaStreamsInfrastructureCustomizer customizes KafkaStreams by delegating to a list of provided KafkaStreamsInfrastructureCustomizer.
CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer...) - Constructor for class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
Construct an instance with the provided customizers.
CompositeProducerInterceptor<K,V> - Class in org.springframework.kafka.support
A ProducerInterceptor that delegates to a collection of interceptors.
CompositeProducerInterceptor(ProducerInterceptor<K, V>...) - Constructor for class org.springframework.kafka.support.CompositeProducerInterceptor
Construct an instance with the provided delegates to ProducerInterceptors.
CompositeProducerListener<K,V> - Class in org.springframework.kafka.support
A ProducerListener that delegates to a collection of listeners.
CompositeProducerListener(ProducerListener<K, V>...) - Constructor for class org.springframework.kafka.support.CompositeProducerListener
 
CompositeRecordInterceptor<K,V> - Class in org.springframework.kafka.listener
A RecordInterceptor that delegates to one or more RecordInterceptors in order.
CompositeRecordInterceptor(RecordInterceptor<K, V>...) - Constructor for class org.springframework.kafka.listener.CompositeRecordInterceptor
Construct an instance with the provided delegates.
concurrency() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
Override the container factory's concurrency setting for this listener.
concurrency() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic
Concurrency for the retry and DLT containers; if not specified, the main container concurrency is used.
concurrency(Integer) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
Configure the concurrency for the retry and DLT containers.
ConcurrentKafkaListenerContainerFactory<K,V> - Class in org.springframework.kafka.config
ConcurrentKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
 
ConcurrentMessageListenerContainer<K,V> - Class in org.springframework.kafka.listener
Creates 1 or more KafkaMessageListenerContainers based on concurrency.
ConcurrentMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
Construct an instance with the supplied configuration properties.
conditionalSleep(Supplier<Boolean>, long) - Static method in class org.springframework.kafka.listener.ListenerUtils
Sleep for the desired timeout, as long as shouldSleepCondition supplies true.
config(String, String) - Method in class org.springframework.kafka.config.TopicBuilder
Set a configuration option.
configs(Map<String, String>) - Method in class org.springframework.kafka.config.TopicBuilder
Set the configs.
configure(C) - Method in interface org.springframework.kafka.config.ContainerCustomizer
Configure the container.
configure(Map<String, ?>) - Method in class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
 
configure(Map<String, ?>) - Method in class org.springframework.kafka.support.CompositeProducerInterceptor
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingByTypeSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.JsonSerde
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.RetryingDeserializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.StringOrBytesSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.ToFromStringSerde
 
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
 
configure(StreamsBuilderFactoryBean) - Method in interface org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer
Configure the factory bean.
configureBlockingRetries(RetryTopicConfigurationSupport.BlockingRetriesConfigurer) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to configure blocking retries parameters such as exceptions to be retried and the BackOff to be used.
configureBuilder(StreamsBuilder) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
 
configureBuilder(StreamsBuilder) - Method in interface org.springframework.kafka.config.KafkaStreamsInfrastructureCustomizer
Configure the builder.
configureCustomizers(RetryTopicConfigurationSupport.CustomizersConfigurer) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to configure customizers for components created by non-blocking retries' configuration, such as MessageListenerContainer, DeadLetterPublishingRecoverer and DefaultErrorHandler.
configureDeadLetterPublishingContainerFactory() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to further configure the DeadLetterPublishingRecovererFactory.
configureDelegate(Map<String, ?>, boolean, Deserializer<?>) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
 
configureDelegate(Map<String, ?>, boolean, Serializer<?>) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerializer
 
configureDelegate(Map<String, ?>, boolean, T) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
Configure the delegate.
configureDestinationTopicResolver() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to configure the DestinationTopicResolver.
configureKafkaListeners(KafkaListenerEndpointRegistrar) - Method in interface org.springframework.kafka.annotation.KafkaListenerConfigurer
Callback allowing a KafkaListenerEndpointRegistry and specific KafkaListenerEndpoint instances to be registered against the given KafkaListenerEndpointRegistrar.
configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
Create a HandlerAdapter for this listener adapter.
configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - Method in class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint
 
configureListenerContainerFactoryConfigurer() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to further configure the ListenerContainerFactoryConfigurer.
configureRetryTopicConfigurer() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method if you need to configure the RetryTopicConfigurer.
configureTopology(Topology) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
 
configureTopology(Topology) - Method in interface org.springframework.kafka.config.KafkaStreamsInfrastructureCustomizer
Configure the topology.
consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to all the embedded topics.
consumeFromAllEmbeddedTopics(Consumer<?, ?>, boolean) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to all the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, boolean, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one of the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one of the embedded topics.
consumeFromEmbeddedTopics(Consumer<?, ?>, boolean, String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one or more of the embedded topics.
consumeFromEmbeddedTopics(Consumer<?, ?>, String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one or more of the embedded topics.
CONSUMER - Static variable in class org.springframework.kafka.support.KafkaHeaders
The header for the Consumer object.
CONSUMER_AWARE - Enum constant in enum class org.springframework.kafka.listener.ListenerType
Consumer aware.
consumerAdded(String, Consumer<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory.Listener
A new consumer was created.
consumerAdded(String, Consumer<K, V>) - Method in class org.springframework.kafka.core.MicrometerConsumerListener
 
ConsumerAwareBatchErrorHandler - Interface in org.springframework.kafka.listener
Deprecated, for removal: This API element is subject to removal in a future version.
in favor of CommonErrorHandler.
ConsumerAwareErrorHandler - Interface in org.springframework.kafka.listener
Deprecated, for removal: This API element is subject to removal in a future version.
in favor of CommonErrorHandler.
ConsumerAwareListenerErrorHandler - Interface in org.springframework.kafka.listener
An error handler that has access to the consumer.
ConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener
Listener for handling individual incoming Kafka messages.
ConsumerAwareRebalanceListener - Interface in org.springframework.kafka.listener
A rebalance listener that provides access to the consumer object.
ConsumerAwareRecordInterceptor<K,V> - Interface in org.springframework.kafka.listener
Deprecated, for removal: This API element is subject to removal in a future version.
ConsumerAwareRecordRecoverer - Interface in org.springframework.kafka.listener
A ConsumerRecordRecoverer that supports getting a reference to the Consumer.
consumerFactory - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer
 
ConsumerFactory<K,V> - Interface in org.springframework.kafka.core
The strategy to produce a Consumer instance(s).
ConsumerFactory.Listener<K,V> - Interface in org.springframework.kafka.core
Called whenever a consumer is added or removed.
ConsumerFailedToStartEvent - Class in org.springframework.kafka.event
An event published when a consumer fails to start.
ConsumerFailedToStartEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ConsumerFailedToStartEvent
Construct an instance with the provided source and container.
consumerGroupHeader(String) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
Sets the name of the header that will be used to store the consumer group that failed to consume the original record.
ConsumerPartitionPausedEvent - Class in org.springframework.kafka.event
An event published when a consumer partition is paused.
ConsumerPartitionPausedEvent(Object, Object, TopicPartition) - Constructor for class org.springframework.kafka.event.ConsumerPartitionPausedEvent
Construct an instance with the provided source and partition.
ConsumerPartitionResumedEvent - Class in org.springframework.kafka.event
An event published when a consumer partition is resumed.
ConsumerPartitionResumedEvent(Object, Object, TopicPartition) - Constructor for class org.springframework.kafka.event.ConsumerPartitionResumedEvent
Construct an instance with the provided source and partition.
ConsumerPausedEvent - Class in org.springframework.kafka.event
An event published when a consumer is paused.
ConsumerPausedEvent(Object, Object, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerPausedEvent
Construct an instance with the provided source and partitions.
ConsumerPausedEvent(Object, Object, Collection<TopicPartition>, String) - Constructor for class org.springframework.kafka.event.ConsumerPausedEvent
Construct an instance with the provided source and partitions.
ConsumerPauseResumeEventPublisher - Interface in org.springframework.kafka.listener
Objects that can publish consumer pause/resume events.
ConsumerPostProcessor<K,V> - Interface in org.springframework.kafka.core
Called by consumer factories to perform post processing on newly created consumers.
ConsumerProperties - Class in org.springframework.kafka.listener
Common consumer properties.
ConsumerProperties(String...) - Constructor for class org.springframework.kafka.listener.ConsumerProperties
Create properties for a container that will subscribe to the specified topics.
ConsumerProperties(Pattern) - Constructor for class org.springframework.kafka.listener.ConsumerProperties
Create properties for a container that will subscribe to topics matching the specified pattern.
ConsumerProperties(TopicPartitionOffset...) - Constructor for class org.springframework.kafka.listener.ConsumerProperties
Create properties for a container that will assign itself the provided topic partitions.
consumerProps(String, String, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> consumer.
consumerProps(String, String, EmbeddedKafkaBroker) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> consumer.
ConsumerRecordKeyCondition(K) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition
 
ConsumerRecordKeyMatcher(K) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
 
ConsumerRecordKeyValueCondition(K, V) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyValueCondition
 
ConsumerRecordMetadata - Class in org.springframework.kafka.listener.adapter
Used to provide a listener method argument when the user supplies such a parameter.
ConsumerRecordMetadata(RecordMetadata, TimestampType) - Constructor for class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
 
ConsumerRecordPartitionCondition(int) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
 
ConsumerRecordPartitionMatcher(int) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
 
ConsumerRecordRecoverer - Interface in org.springframework.kafka.listener
A BiConsumer extension for recovering consumer records.
ConsumerRecordTimestampCondition(TimestampType, long) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition
 
ConsumerRecordTimestampMatcher(TimestampType, long) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
 
ConsumerRecordValueCondition(V) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition
 
ConsumerRecordValueMatcher(V) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
 
consumerRemoved(String, Consumer<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory.Listener
An existing consumer was removed.
consumerRemoved(String, Consumer<K, V>) - Method in class org.springframework.kafka.core.MicrometerConsumerListener
 
ConsumerResumedEvent - Class in org.springframework.kafka.event
An event published when a consumer is resumed.
ConsumerResumedEvent(Object, Object, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerResumedEvent
Construct an instance with the provided source and partitions.
ConsumerRetryAuthEvent - Class in org.springframework.kafka.event
An event published when authentication or authorization of a consumer fails and is being retried.
ConsumerRetryAuthEvent(Object, Object, ConsumerRetryAuthEvent.Reason) - Constructor for class org.springframework.kafka.event.ConsumerRetryAuthEvent
Construct an instance with the provided source and container.
ConsumerRetryAuthEvent.Reason - Enum Class in org.springframework.kafka.event
Reasons for retrying auth a consumer.
ConsumerRetryAuthSuccessfulEvent - Class in org.springframework.kafka.event
An event published when authentication or authorization has been retried successfully.
ConsumerRetryAuthSuccessfulEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ConsumerRetryAuthSuccessfulEvent
Construct an instance with the provided source and container.
ConsumerSeekAware - Interface in org.springframework.kafka.listener
Listeners that implement this interface are provided with a ConsumerSeekAware.ConsumerSeekCallback which can be used to perform a seek operation.
ConsumerSeekAware.ConsumerSeekCallback - Interface in org.springframework.kafka.listener
A callback that a listener can invoke to seek to a specific offset.
ConsumerStartedEvent - Class in org.springframework.kafka.event
An event published when a consumer has started.
ConsumerStartedEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ConsumerStartedEvent
Construct an instance with the provided source and container.
ConsumerStartingEvent - Class in org.springframework.kafka.event
An event published when a consumer is initializing.
ConsumerStartingEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ConsumerStartingEvent
Construct an instance with the provided source and container.
ConsumerStoppedEvent - Class in org.springframework.kafka.event
An event published when a consumer is stopped.
ConsumerStoppedEvent(Object, Object, ConsumerStoppedEvent.Reason) - Constructor for class org.springframework.kafka.event.ConsumerStoppedEvent
Construct an instance with the provided source and container.
ConsumerStoppedEvent.Reason - Enum Class in org.springframework.kafka.event
Reasons for stopping a consumer.
ConsumerStoppingEvent - Class in org.springframework.kafka.event
An event published when a consumer is stopped.
ConsumerStoppingEvent(Object, Object, Consumer<?, ?>, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerStoppingEvent
Construct an instance with the provided source, consumer and partitions.
ContainerAwareBatchErrorHandler - Interface in org.springframework.kafka.listener
Deprecated, for removal: This API element is subject to removal in a future version.
in favor of CommonErrorHandler.
ContainerAwareErrorHandler - Interface in org.springframework.kafka.listener
Deprecated, for removal: This API element is subject to removal in a future version.
in favor of CommonErrorHandler.
ContainerCustomizer<K,V,C extends AbstractMessageListenerContainer<K,V>> - Interface in org.springframework.kafka.config
Called by the container factory after the container is created and configured.
containerFactory() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
The bean name of the KafkaListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.
containerGroup() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
If provided, the listener container for this listener will be added to a bean with this value as its name, of type Collection<MessageListenerContainer>.
ContainerGroup - Class in org.springframework.kafka.listener
A group of listener containers.
ContainerGroup(String) - Constructor for class org.springframework.kafka.listener.ContainerGroup
Construct an instance with the provided name.
ContainerGroup(String, List<MessageListenerContainer>) - Constructor for class org.springframework.kafka.listener.ContainerGroup
Construct an instance with the provided name and containers.
ContainerGroup(String, MessageListenerContainer...) - Constructor for class org.springframework.kafka.listener.ContainerGroup
Construct an instance with the provided name and containers.
ContainerGroupSequencer - Class in org.springframework.kafka.listener
Sequence the starting of container groups when all containers in the previous group are idle.
ContainerGroupSequencer(ListenerContainerRegistry, long, String...) - Constructor for class org.springframework.kafka.listener.ContainerGroupSequencer
Set containers in each group to not auto start.
ContainerPartitionPausingBackOffManager - Class in org.springframework.kafka.listener
A manager that backs off consumption for a given topic if the timestamp provided is not due.
ContainerPartitionPausingBackOffManager(ListenerContainerRegistry, BackOffHandler) - Constructor for class org.springframework.kafka.listener.ContainerPartitionPausingBackOffManager
Construct an instance with the provided registry and back off handler.
ContainerPartitionPausingBackOffManagerFactory - Class in org.springframework.kafka.listener
ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry, ApplicationContext) - Constructor for class org.springframework.kafka.listener.ContainerPartitionPausingBackOffManagerFactory
Construct an instance with the provided properties.
ContainerPausingBackOffHandler - Class in org.springframework.kafka.listener
A BackOffHandler that pauses the container for the backoff.
ContainerPausingBackOffHandler(ListenerContainerPauseService) - Constructor for class org.springframework.kafka.listener.ContainerPausingBackOffHandler
Create an instance with the provided ListenerContainerPauseService.
ContainerProperties - Class in org.springframework.kafka.listener
Contains runtime properties for a listener container.
ContainerProperties(String...) - Constructor for class org.springframework.kafka.listener.ContainerProperties
Create properties for a container that will subscribe to the specified topics.
ContainerProperties(Pattern) - Constructor for class org.springframework.kafka.listener.ContainerProperties
Create properties for a container that will subscribe to topics matching the specified pattern.
ContainerProperties(TopicPartitionOffset...) - Constructor for class org.springframework.kafka.listener.ContainerProperties
Create properties for a container that will assign itself the provided topic partitions.
ContainerProperties.AckMode - Enum Class in org.springframework.kafka.listener
The offset commit behavior enumeration.
ContainerProperties.AssignmentCommitOption - Enum Class in org.springframework.kafka.listener
Offset commit behavior during assignment.
ContainerProperties.EOSMode - Enum Class in org.springframework.kafka.listener
Mode for exactly once semantics.
ContainerStoppedEvent - Class in org.springframework.kafka.event
An event published when a container is stopped.
ContainerStoppedEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ContainerStoppedEvent
Construct an instance with the provided source and container.
ContainerTestUtils - Class in org.springframework.kafka.test.utils
Utilities for testing listener containers.
contains(MessageListenerContainer) - Method in class org.springframework.kafka.listener.ContainerGroup
Return true if the provided container is in this group.
contentTypeConverter() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
Set the bean name of a SmartMessageConverter (such as the CompositeMessageConverter) to use in conjunction with the MessageHeaders.CONTENT_TYPE header to perform the conversion to the required type.
Context(String, List<DestinationTopic.Properties>) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopicProcessor.Context
 
controlledShutdown() - Element in annotation interface org.springframework.kafka.test.context.EmbeddedKafka
 
CONVERSION_FAILURES - Static variable in class org.springframework.kafka.support.KafkaHeaders
The header containing a list of conversion failures (for batch listeners only).
ConversionException - Exception in org.springframework.kafka.support.converter
Exception for conversions.
ConversionException(String, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
Construct an instance with the provided properties.
ConversionException(String, List<ConsumerRecord<?, ?>>, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
Construct an instance with the provided properties.
ConversionException(String, ConsumerRecord<?, ?>, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
Construct an instance with the provided properties.
ConversionException(String, Message<?>, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
Construct an instance with the provided properties.
convert(ConsumerRecord<?, ?>, Type, List<ConversionException>) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
Convert the record value.
convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter
 
ConvertingMessageListener<V> - Class in org.springframework.kafka.listener.adapter
A AcknowledgingConsumerAwareMessageListener adapter that implements converting received ConsumerRecord using specified MessageConverter and then passes result to specified MessageListener.
ConvertingMessageListener(MessageListener<?, V>, Class<V>) - Constructor for class org.springframework.kafka.listener.adapter.ConvertingMessageListener
Construct an instance with the provided MessageListener and Class as a desired type of ConsumerRecord's value after conversion.
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter
 
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.BytesJsonMessageConverter
 
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
 
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
Subclasses can convert the payload; by default, it's sent unchanged to Kafka.
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.ProjectingMessageConverter
 
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.StringJsonMessageConverter
 
copyWithConfigurationOverride(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
Copy properties of the instance and the given properties to create a new producer factory.
copyWithConfigurationOverride(Map<String, Object>) - Method in interface org.springframework.kafka.core.ProducerFactory
Copy the properties of the instance and the given properties to create a new producer factory.
copyWithType(TypeReference<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
Copies this deserializer with same configuration, except new target type reference is used.
copyWithType(TypeReference<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonSerde
Copies this serde with same configuration, except new target type reference is used.
copyWithType(TypeReference<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
Copies this serializer with same configuration, except new target type reference is used.
copyWithType(JavaType) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
Copies this deserializer with same configuration, except new target java type is used.
copyWithType(JavaType) - Method in class org.springframework.kafka.support.serializer.JsonSerde
Copies this serde with same configuration, except new target java type is used.
copyWithType(JavaType) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
Copies this serializer with same configuration, except new target java type is used.
copyWithType(Class<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
Copies this deserializer with same configuration, except new target type is used.
copyWithType(Class<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonSerde
Copies this serde with same configuration, except new target type is used.
copyWithType(Class<? super X>) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
Copies this serializer with same configuration, except new target type reference is used.
CORRELATION_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders
The header containing information to correlate requests/replies.
CorrelationKey - Class in org.springframework.kafka.requestreply
Wrapper for byte[] that can be used as a hash key.
CorrelationKey(byte[]) - Constructor for class org.springframework.kafka.requestreply.CorrelationKey
 
count() - Element in annotation interface org.springframework.kafka.test.context.EmbeddedKafka
 
COUNT - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode
Commit pending offsets after ackCount has been exceeded.
COUNT_PROPERTY_NAME - Static variable in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener
The number of brokers for EmbeddedKafkaBroker.
COUNT_TIME - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode
Commit pending offsets after ackCount has been exceeded or after ackTime has elapsed.
create() - Method in class org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
 
create() - Method in interface org.springframework.kafka.listener.KafkaBackOffManagerFactory
 
create(String) - Method in class org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory
 
create(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Method in interface org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator
Create a DeadLetterPublishingRecoverer using the supplied properties.
create(Headers, Exception, boolean, DeadLetterPublishingRecoverer.HeaderNames) - Method in interface org.springframework.kafka.listener.DeadLetterPublishingRecoverer.ExceptionHeadersCreator
Create exception headers.
create(KafkaOperations<?, ?>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
Create the RetryTopicConfiguration with the provided template.
createAccessor(Message<?>) - Method in class org.springframework.kafka.support.KafkaMessageHeaderAccessor
 
createComponentFactory() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport
Override this method to provide a subclass of RetryTopicComponentFactory with different component implementations or subclasses.
createConsumer() - Method in interface org.springframework.kafka.core.ConsumerFactory
Create a consumer with the group id and client id as configured in the properties.
createConsumer(String) - Method in interface org.springframework.kafka.core.ConsumerFactory
Create a consumer, appending the suffix to the client.id property, if present.
createConsumer(String, String) - Method in interface org.springframework.kafka.core.ConsumerFactory
Create a consumer with an explicit group id; in addition, the client id suffix is appended to the client.id property, if both are present.
createConsumer(String, String, String) - Method in interface org.springframework.kafka.core.ConsumerFactory
Create a consumer with an explicit group id; in addition, the client id suffix is appended to the clientIdPrefix which overrides the client.id property, if present.
createConsumer(String, String, String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
 
createConsumer(String, String, String) - Method in class org.springframework.kafka.mock.MockConsumerFactory
 
createConsumer(String, String, String, Properties) - Method in interface org.springframework.kafka.core.ConsumerFactory
Create a consumer with an explicit group id; in addition, the client id suffix is appended to the clientIdPrefix which overrides the client.id property, if present.
createConsumer(String, String, String, Properties) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
 
createConsumer(String, String, String, Properties) - Method in class org.springframework.kafka.mock.MockConsumerFactory
 
createContainer(String...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
 
createContainer(String...) - Method in interface org.springframework.kafka.config.KafkaListenerContainerFactory
Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.
createContainer(Pattern) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
 
createContainer(Pattern) - Method in interface org.springframework.kafka.config.KafkaListenerContainerFactory
Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.
createContainer(TopicPartitionOffset...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
 
createContainer(TopicPartitionOffset...) - Method in interface org.springframework.kafka.config.KafkaListenerContainerFactory
Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.
createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
Create an empty container instance.
createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
 
createContext(long, String, TopicPartition, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.KafkaConsumerBackoffManager
 
createDefaultErrorHandlerInstance(DeadLetterPublishingRecoverer) - Method in class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
 
createDelegates(String, Map<String, ?>, boolean) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
 
createDelegates(String, Map<String, ?>, boolean) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer
 
createEndpointCustomizer() - Method in class org.springframework.kafka.retrytopic.EndpointCustomizerFactory
 
createEndpointCustomizer(EndpointHandlerMethod, DestinationTopic.Properties) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer
 
createErrorHandler(DeadLetterPublishingRecoverer, ListenerContainerFactoryConfigurer.Configuration) - Method in class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
 
createHandlerMethodWith(Object, Method) - Static method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer
 
createHandlerMethodWith(Object, String) - Static method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer
 
createInstance() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
 
createInstanceAndConfigure(Map<String, ?>, boolean, Map<String, Deserializer<?>>, String, String) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
 
createInstanceAndConfigure(Map<String, ?>, boolean, Map<String, Serializer<?>>, String, String) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer
 
createInternalRetryTopicClock() - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory
Create a Clock instance that will be used for all time-related operations in the retry topic processes.
createKafkaConsumer(String, String, String, Properties) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
 
createKafkaConsumer(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
 
createKafkaProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
Subclasses must return a raw producer which will be wrapped in a DefaultKafkaProducerFactory.CloseSafeProducer.
createListenerContainer(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
 
createListenerContainer(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.config.KafkaListenerContainerFactory
createListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
Create and start a new MessageListenerContainer using the specified factory.
createManagerFor(Collection<T>, Collection<T>) - Static method in class org.springframework.kafka.support.AllowDenyCollectionManager
 
createManagerFor(Collection<T>, Collection<T>, Collection<Predicate<T>>) - Static method in class org.springframework.kafka.support.AllowDenyCollectionManager
 
createMappings(String) - Static method in class org.springframework.kafka.support.serializer.JsonSerializer
 
createMessageListener(MessageListenerContainer, MessageConverter) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
Create a MessageListener that is able to serve this endpoint for the specified container.
createMessageListener(MessageListenerContainer, MessageConverter) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
 
createMessageListenerInstance(MessageConverter) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
Create an empty MessagingMessageListenerAdapter instance.
createMessagingErrorMessage(String, Object) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
createNewTopicBeans(Collection<String>, RetryTopicConfiguration.TopicCreation) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer
 
createNonTransactionalProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
 
createNonTransactionalProducer() - Method in interface org.springframework.kafka.core.ProducerFactory
Create a non-transactional producer.
createNonTransactionalProducer() - Method in class org.springframework.kafka.mock.MockProducerFactory
 
createOffsetAndMetadata(MessageListenerContainer, long) - Static method in class org.springframework.kafka.listener.ListenerUtils
Create a new OffsetAndMetadata using the given container and offset.
createOrModifyTopics(NewTopic...) - Method in class org.springframework.kafka.core.KafkaAdmin
 
createOrModifyTopics(NewTopic...) - Method in interface org.springframework.kafka.core.KafkaAdminOperations
Create topics if they don't exist or increase the number of partitions if needed.
createProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
 
createProducer() - Method in interface org.springframework.kafka.core.ProducerFactory
Create a producer which will be transactional if the factory is so configured.
createProducer() - Method in class org.springframework.kafka.mock.MockProducerFactory
 
createProducer(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
 
createProducer(String) - Method in interface org.springframework.kafka.core.ProducerFactory
Create a producer with an overridden transaction id prefix.
createProducer(String) - Method in class org.springframework.kafka.mock.MockProducerFactory
 
createProducerRecord(ConsumerRecord<?, ?>, TopicPartition, Headers, byte[], byte[]) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
Subclasses can override this method to customize the producer record to send to the DLQ.
createProperties() - Method in class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory
 
createRawConsumer(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
Create a Consumer.
createRawProducer(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
 
createRetryTopicNamesProvider(DestinationTopic.Properties) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory
 
createRetryTopicNamesProvider(DestinationTopic.Properties) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory
 
createSimpleLoggingConsumerRebalanceListener() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
Return default implementation of ConsumerRebalanceListener instance.
createTransactionalProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
Subclasses must return a producer from the DefaultKafkaProducerFactory.getCache() or a new raw producer wrapped in a DefaultKafkaProducerFactory.CloseSafeProducer.
createTransactionalProducer(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
 
customBackoff(SleepingBackOffPolicy<?>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
Configure a custom SleepingBackOffPolicy.
customize(KafkaStreams) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsCustomizer
 
customize(KafkaStreams) - Method in interface org.springframework.kafka.config.KafkaStreamsCustomizer
 
customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider, MethodKafkaListenerEndpoint<?, ?>) - Method in class org.springframework.kafka.retrytopic.EndpointCustomizerFactory
 
customizeDeadLetterPublishingRecoverer(Consumer<DeadLetterPublishingRecoverer>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
Customize the DeadLetterPublishingRecoverer that will be used to forward the records to the retry topics and DLT.
customizeEndpointAndCollectTopics(MethodKafkaListenerEndpoint<?, ?>) - Method in interface org.springframework.kafka.retrytopic.EndpointCustomizer
Customize the endpoint and return the topic names generated for this endpoint.
customizeErrorHandler(Consumer<DefaultErrorHandler>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
Customize the CommonErrorHandler instances that will be used for the feature.
customizeListenerContainer(Consumer<ConcurrentMessageListenerContainer<?, ?>>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
Customize the ConcurrentMessageListenerContainer instances created for the retry and DLT consumers.
CustomizersConfigurer() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
 
A B C D E F G H I J K L M N O P R S T U V W Z 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form