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

R

RAW_DATA - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the raw data received from Kafka (ConsumerRecord or ConsumerRecords).

ReactiveKafkaConsumerTemplate<K,V> - Class in org.springframework.kafka.core.reactive

Reactive kafka consumer operations implementation.

ReactiveKafkaConsumerTemplate(KafkaReceiver<K, V>) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

ReactiveKafkaConsumerTemplate(ReceiverOptions<K, V>) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

ReactiveKafkaProducerTemplate<K,V> - Class in org.springframework.kafka.core.reactive

Reactive kafka producer operations implementation.

ReactiveKafkaProducerTemplate(KafkaSender<K, V>) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate

ReactiveKafkaProducerTemplate(KafkaSender<K, V>, RecordMessageConverter) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate

ReactiveKafkaProducerTemplate(SenderOptions<K, V>) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate

ReactiveKafkaProducerTemplate(SenderOptions<K, V>, RecordMessageConverter) - Constructor for class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate

receive() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

receive(String, int, long) - Method in interface org.springframework.kafka.core.KafkaOperations

Receive a single record with the default poll timeout (5 seconds).

receive(String, int, long, Duration) - Method in interface org.springframework.kafka.core.KafkaOperations

Receive a single record.

receive(String, int, long, Duration) - Method in class org.springframework.kafka.core.KafkaTemplate

receive(Collection<TopicPartitionOffset>) - Method in interface org.springframework.kafka.core.KafkaOperations

Receive a multiple records with the default poll timeout (5 seconds).

receive(Collection<TopicPartitionOffset>, Duration) - Method in interface org.springframework.kafka.core.KafkaOperations

Receive multiple records.

receive(Collection<TopicPartitionOffset>, Duration) - Method in class org.springframework.kafka.core.KafkaTemplate

receiveAtMostOnce() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

receiveAutoAck() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

receiveBatch() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

RECEIVED - Static variable in class org.springframework.kafka.support.KafkaHeaders

The prefix for Kafka headers containing 'received' values.

RECEIVED_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the record key from the received message.

RECEIVED_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the topic partition from the received message.

RECEIVED_TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header for holding the timestamp of the consumer record.

RECEIVED_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the topic from which the message was received.

receiveExactlyOnce(TransactionManager) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

Returns a Flux of consumer record batches that may be used for exactly once delivery semantics.

RECORD - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

Commit the offset after each record is processed by the listener.

RECORD_METADATA - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the RecordMetadata object after successful send to the topic.

RecordFilterStrategy<K,V> - Interface in org.springframework.kafka.listener.adapter

Implementations of this interface can signal that a record about to be delivered to a message listener should be discarded instead of being delivered.

RecordInterceptor<K,V> - Interface in org.springframework.kafka.listener

An interceptor for ConsumerRecord invoked by the listener container before and after invoking the listener.

RecordMessageConverter - Interface in org.springframework.kafka.support.converter

A Kafka-specific Message converter strategy.

RecordMessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.

RecordMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter

RecordMessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - Constructor for class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter

recordsToString(ConsumerRecords<?, ?>) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

Represent the records as a comma-delimited String of topic-part@offset.

recovered(ConsumerRecord<?, ?>, Exception) - Method in interface org.springframework.kafka.listener.RetryListener

Called after a failing record was successfully recovered.

recovered(ConsumerRecord<?, ?>, Exception, MessageListenerContainer, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.RecoveryStrategy

Return true if the record should be skipped because it was successfully recovered.

recovered(ConsumerRecords<?, ?>, Exception) - Method in interface org.springframework.kafka.listener.RetryListener

Called after a failing record was successfully recovered.

RecoveringDeserializationExceptionHandler - Class in org.springframework.kafka.streams

A DeserializationExceptionHandler that calls a ConsumerRecordRecoverer.

RecoveringDeserializationExceptionHandler() - Constructor for class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler

RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer) - Constructor for class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler

recoveryFailed(ConsumerRecord<?, ?>, Exception, Exception) - Method in interface org.springframework.kafka.listener.RetryListener

Called after a recovery attempt failed.

recoveryFailed(ConsumerRecords<?, ?>, Exception, Exception) - Method in interface org.springframework.kafka.listener.RetryListener

Called after a recovery attempt failed.

RecoveryStrategy - Interface in org.springframework.kafka.listener

Called to determine whether a record should be skipped.

registerAllEndpoints() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.kafka.annotation.KafkaBootstrapConfiguration

registerDestinationTopic(String, String, DestinationTopic.Properties, DestinationTopicProcessor.Context) - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicProcessor

registerDestinationTopic(String, String, DestinationTopic.Properties, DestinationTopicProcessor.Context) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicProcessor

Register the destination topic.

registerEndpoint(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Register a new KafkaListenerEndpoint using the default KafkaListenerContainerFactory to create the underlying container.

registerEndpoint(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Register a new KafkaListenerEndpoint alongside the KafkaListenerContainerFactory to use to create the underlying container.

registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.kafka.aot.KafkaRuntimeHints

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Create a message listener container for the given KafkaListenerEndpoint.

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>, boolean) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Create a message listener container for the given KafkaListenerEndpoint.

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware

Register the callback to use when seeking at some arbitrary time.

relativeToCurrent() - Element in annotation interface org.springframework.kafka.annotation.PartitionOffset

By default, positive PartitionOffset.initialOffset() is absolute, negative is relative to the current topic end.

releaseResources(KafkaResourceHolder<K, V>) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils

releaseSuffix(String, String) - Method in class org.springframework.kafka.core.DefaultTransactionIdSuffixStrategy

releaseSuffix(String, String) - Method in interface org.springframework.kafka.core.TransactionIdSuffixStrategy

Release the suffix for the transactional producer.

REMOVE_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

Kafka config property for removing type headers (default true).

removeClassification(Class<? extends Exception>) - Method in class org.springframework.kafka.listener.ExceptionClassifier

Remove an exception type from the configured list.

removeClassification(Class<? extends Exception>) - Method in class org.springframework.kafka.listener.FailedBatchProcessor

removeConfig(String) - Method in interface org.springframework.kafka.core.ConsumerFactory

Remove the specified key from the configuration map.

removeConfig(String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

removeConfig(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

removeConfig(String) - Method in interface org.springframework.kafka.core.ProducerFactory

Remove the specified key from the configuration map.

removeContainer(MessageListenerContainer) - Method in class org.springframework.kafka.listener.ContainerGroup

Remove a container from the group.

removeDelegate(String) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer

removeDelegate(String) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer

removeDelegate(Pattern) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization

removeDelegate(ProducerListener<K, V>) - Method in class org.springframework.kafka.support.CompositeProducerListener

removeHeaders(Headers) - Method in class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper

removeHeaders(Headers) - Method in interface org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper

Remove the type information headers.

removeListener(StreamsBuilderFactoryBean.Listener) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean

Remove a listener.

removeListener(ConsumerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory

Remove a listener.

removeListener(ConsumerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

Remove a listener.

removeListener(ProducerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

Remove a listener.

removeListener(ProducerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory

Remove a listener.

removeNotRetryableException(Class<? extends Exception>) - Method in class org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory

Remove an exception type from the configured list.

removePostProcessor(ConsumerPostProcessor<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory

Remove a post processor.

removePostProcessor(ConsumerPostProcessor<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

removePostProcessor(ProducerPostProcessor<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

removePostProcessor(ProducerPostProcessor<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory

Remove a post processor.

removeProducer(DefaultKafkaProducerFactory.CloseSafeProducer<K, V>, Duration) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

Remove the single shared producer and a thread-bound instance if present.

renderProperties() - Method in class org.springframework.kafka.listener.ConsumerProperties

replicas(int) - Method in class org.springframework.kafka.config.TopicBuilder

Set the number of replicas (default broker 'default.replication.factor').

replicasAssignments(Map<Integer, List<Integer>>) - Method in class org.springframework.kafka.config.TopicBuilder

Set the replica assignments.

replicationFactor() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

The replication factor for the automatically created topics.

REPLY_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing a partition number on which to send the reply.

REPLY_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the default reply topic.

ReplyExpressionRoot(Object, Object, Object) - Constructor for record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

Creates an instance of a ReplyExpressionRoot record class.

ReplyHeadersConfigurer - Interface in org.springframework.kafka.listener.adapter

A strategy for configuring which headers, if any, should be set in a reply message.

ReplyingKafkaOperations<K,V,R> - Interface in org.springframework.kafka.requestreply

Request/reply operations.

ReplyingKafkaTemplate<K,V,R> - Class in org.springframework.kafka.requestreply

A KafkaTemplate that implements request/reply semantics.

ReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, R>) - Constructor for class org.springframework.kafka.requestreply.ReplyingKafkaTemplate

ReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, R>, boolean) - Constructor for class org.springframework.kafka.requestreply.ReplyingKafkaTemplate

request() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

Returns the value of the request record component.

RequestReplyFuture<K,V,R> - Class in org.springframework.kafka.requestreply

A CompletableFuture for requests/replies.

RequestReplyFuture() - Constructor for class org.springframework.kafka.requestreply.RequestReplyFuture

RequestReplyMessageFuture<K,V> - Class in org.springframework.kafka.requestreply

A listenable future for Message replies.

RequestReplyTypedMessageFuture<K,V,P> - Class in org.springframework.kafka.requestreply

A listenable future for Message replies with a specific payload type.

REQUIRED - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag

Required - The LoginModule is required to succeed.

REQUISITE - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag

Requisite - The LoginModule is required to succeed.

reset() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

Close the Producer(s) and clear the cache of transactional Producer(s).

reset() - Method in interface org.springframework.kafka.core.ProducerFactory

Reset any state in the factory, if supported.

resolveArgument(MethodParameter, Message<?>) - Method in class org.springframework.kafka.listener.adapter.ContinuationHandlerMethodArgumentResolver

resolveArgument(MethodParameter, Message<?>) - Method in class org.springframework.kafka.listener.adapter.KafkaNullAwarePayloadArgumentResolver

resolveBean(BeanFactory) - Method in class org.springframework.kafka.support.EndpointHandlerMethod

resolveDestinationTopic(String, String, Integer, Exception, long) - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver

resolveDestinationTopic(String, String, Integer, Exception, long) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicResolver

Resolves the destination topic for the failed message.

resolveParameter(ParameterContext, ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition

resolveTopicPartition(ConsumerRecord<?, ?>, DestinationTopic) - Method in class org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory

Creates and returns the TopicPartition, where the original record should be forwarded.

resolveType(String, byte[], Headers) - Method in interface org.springframework.kafka.support.serializer.JsonTypeResolver

Determine the type.

restart(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

result() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

Returns the value of the result record component.

result() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

Returns the value of the result record component.

resume() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

resume() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

resume() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

resume() - Method in interface org.springframework.kafka.listener.MessageListenerContainer

Resume this container, if paused, after the next poll().

resume(String) - Method in class org.springframework.kafka.listener.ListenerContainerPauseService

Resume the listener container by given id.

resume(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

resume(MessageListenerContainer) - Method in class org.springframework.kafka.listener.ListenerContainerPauseService

Resume the listener container.

resumePartition(TopicPartition) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

resumePartition(TopicPartition) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

resumePartition(TopicPartition) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

resumePartition(TopicPartition) - Method in interface org.springframework.kafka.listener.MessageListenerContainer

Resume this partition, if paused, after the next poll().

retrieveHeader(Headers, String) - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

retrieveHeaderAsString(Headers, String) - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

retrieveQueryableStore(String, QueryableStoreType<T>) - Method in class org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService

Retrieve and return a queryable store by name created in the application.

RETRY_TOPIC_CONFIGURER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

The bean name of the internally managed retry topic configurer.

RetryableTopic - Annotation Interface in org.springframework.kafka.annotation

Annotation to create the retry and dlt topics for a KafkaListener annotated listener.

RetryableTopicAnnotationProcessor - Class in org.springframework.kafka.annotation

Processes the provided RetryableTopic annotation returning an RetryTopicConfiguration.

RetryableTopicAnnotationProcessor(BeanFactory) - Constructor for class org.springframework.kafka.annotation.RetryableTopicAnnotationProcessor

Construct an instance using the provided parameters and default resolver, expression context.

RetryableTopicAnnotationProcessor(BeanFactory, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.kafka.annotation.RetryableTopicAnnotationProcessor

Construct an instance using the provided parameters.

retryBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable, BackOff, CommonErrorHandler, BiConsumer<ConsumerRecords<?, ?>, Exception>, LogAccessor, KafkaException.Level, List<RetryListener>, BinaryExceptionClassifier, boolean) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

Retry a complete batch by pausing the consumer and then, in a loop, poll the consumer, wait for the next back off, then call the listener.

RetryingDeserializer<T> - Class in org.springframework.kafka.support.serializer

A deserializer configured with a delegate and a RetryOperations to retry deserialization in case of transient errors.

RetryingDeserializer(Deserializer<T>, RetryOperations) - Constructor for class org.springframework.kafka.support.serializer.RetryingDeserializer

RetryListener - Interface in org.springframework.kafka.listener

A listener for retry activity.

retryOn(Class<? extends Exception>...) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.BlockingRetriesConfigurer

Set the exceptions that should be retried by the blocking retry mechanism.

retryOn(Class<? extends Throwable>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the behavior to retry on the provided Throwable.

retryOn(List<Class<? extends Throwable>>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the behavior to retry on the provided Throwables.

RetryTopicBeanNames - Class in org.springframework.kafka.retrytopic

The bean names for the non-blocking topic-based delayed retries feature.

RetryTopicComponentFactory - Class in org.springframework.kafka.retrytopic

Provide the component instances that will be used with RetryTopicConfigurationSupport.

RetryTopicComponentFactory() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicComponentFactory

RetryTopicConfiguration - Class in org.springframework.kafka.retrytopic

Contains the provided configuration for the retryable topics.

RetryTopicConfigurationBuilder - Class in org.springframework.kafka.retrytopic

Builder class to create RetryTopicConfiguration instances.

RetryTopicConfigurationBuilder() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

RetryTopicConfigurationProvider - Class in org.springframework.kafka.annotation

Attempts to provide an instance of RetryTopicConfiguration by either creating one from a RetryableTopic annotation, or from the bean container if no annotation is available.

RetryTopicConfigurationProvider(BeanFactory) - Constructor for class org.springframework.kafka.annotation.RetryTopicConfigurationProvider

Construct an instance using the provided bean factory and default resolver and bean expression context.

RetryTopicConfigurationProvider(BeanFactory, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.kafka.annotation.RetryTopicConfigurationProvider

Construct an instance using the provided parameters.

RetryTopicConfigurationSupport - Class in org.springframework.kafka.retrytopic

This is the main class providing the configuration behind the non-blocking, topic-based delayed retries feature.

RetryTopicConfigurationSupport() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport

RetryTopicConfigurationSupport.BlockingRetriesConfigurer - Class in org.springframework.kafka.retrytopic

Configure blocking retries to be used along non-blocking.

RetryTopicConfigurationSupport.CustomizersConfigurer - Class in org.springframework.kafka.retrytopic

Configure customizers for components instantiated by the retry topics feature.

retryTopicConfigurer(KafkaConsumerBackoffManager, DestinationTopicResolver, ObjectProvider<RetryTopicComponentFactory>, BeanFactory) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport

Return a global RetryTopicConfigurer for configuring retry topics for KafkaListenerEndpoint instances with a corresponding RetryTopicConfiguration.

retryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryConfigurer, ListenerContainerFactoryResolver, RetryTopicNamesProviderFactory) - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory

Create the RetryTopicConfigurer that will serve as an entry point for configuring non-blocking topic-based delayed retries for a given KafkaListenerEndpoint, by processing the appropriate RetryTopicConfiguration.

RetryTopicConfigurer - Class in org.springframework.kafka.retrytopic

Configures main, retry and DLT topics based on a main endpoint and provided configurations to accomplish a distributed retry / DLT pattern in a non-blocking fashion, at the expense of ordering guarantees.

RetryTopicConfigurer(DestinationTopicProcessor, ListenerContainerFactoryResolver, ListenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory) - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConfigurer

Create an instance with the provided properties.

RetryTopicConfigurer.EndpointProcessor - Interface in org.springframework.kafka.retrytopic

RetryTopicConstants - Class in org.springframework.kafka.retrytopic

Constants for the RetryTopic functionality.

RetryTopicConstants() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConstants

RetryTopicHeaders - Class in org.springframework.kafka.retrytopic

Contains the headers that will be used in the forwarded messages.

RetryTopicHeaders() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicHeaders

retryTopicNamesProviderFactory() - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory

Create the RetryTopicNamesProviderFactory instance that will be used to provide the property names for the retry topics' KafkaListenerEndpoint.

RetryTopicNamesProviderFactory - Interface in org.springframework.kafka.retrytopic

Handles the naming related to the retry and dead letter topics.

RetryTopicNamesProviderFactory.RetryTopicNamesProvider - Interface in org.springframework.kafka.retrytopic

RetryTopicSchedulerWrapper - Class in org.springframework.kafka.retrytopic

A wrapper class for a TaskScheduler to use for scheduling container resumption when a partition has been paused for a retry topic.

RetryTopicSchedulerWrapper(TaskScheduler) - Constructor for class org.springframework.kafka.retrytopic.RetryTopicSchedulerWrapper

Create a wrapper for the supplied scheduler.

retryTopicSuffix() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

The suffix that will be appended to the main topic in order to generate the retry topics.

retryTopicSuffix(String) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the suffix to add to the retry topics.

returnTypeMessageOrCollectionOf(Method) - Static method in class org.springframework.kafka.support.KafkaUtils

Return true if the method return type is Message or Collection<Message<?>>.

revertLevels(String, JUnitUtils.LevelsContainer) - Static method in class org.springframework.kafka.test.utils.JUnitUtils

rollback() - Method in class org.springframework.kafka.core.KafkaResourceHolder

RoutingKafkaTemplate - Class in org.springframework.kafka.core

A KafkaTemplate that routes messages based on the topic name.

RoutingKafkaTemplate(Map<Pattern, ProducerFactory<Object, Object>>) - Constructor for class org.springframework.kafka.core.RoutingKafkaTemplate

Construct an instance with the provided properties.

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