D-Index (Spring for Apache Kafka 3.2.4 API)

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

D

DeadLetterPublishingRecoverer - Class in org.springframework.kafka.listener: A ConsumerRecordRecoverer that publishes a failed record to a dead-letter topic.
DeadLetterPublishingRecoverer(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, boolean, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with a template resolving function that receives the failed consumer record and the exception and returns a KafkaOperations and a flag on whether or not the publishing from this instance will be transactional or not.
DeadLetterPublishingRecoverer(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with a template resolving function that receives the failed consumer record and the exception and returns a KafkaOperations and a flag on whether or not the publishing from this instance will be transactional or not.
DeadLetterPublishingRecoverer(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with the provided templates and a default destination resolving function that returns a TopicPartition based on the original topic (appended with ".DLT") from the failed record, and the same partition as the failed record.
DeadLetterPublishingRecoverer(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with the provided templates and destination resolving function, that receives the failed consumer record and the exception and returns a TopicPartition.
DeadLetterPublishingRecoverer(KafkaOperations<? extends Object, ? extends Object>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with the provided template and a default destination resolving function that returns a TopicPartition based on the original topic (appended with ".DLT") from the failed record, and the same partition as the failed record.
DeadLetterPublishingRecoverer(KafkaOperations<? extends Object, ? extends Object>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Create an instance with the provided template and destination resolving function, that receives the failed consumer record and the exception and returns a TopicPartition.
DeadLetterPublishingRecoverer.ExceptionHeadersCreator - Interface in org.springframework.kafka.listener: Use this to provide a custom implementation to take complete control over exception header creation for the output record.
DeadLetterPublishingRecoverer.HeaderNames - Class in org.springframework.kafka.listener: Container class for the name of the headers that will be added to the produced record.
DeadLetterPublishingRecoverer.HeaderNames.Builder - Class in org.springframework.kafka.listener: Provides a convenient API for creating DeadLetterPublishingRecoverer.HeaderNames.
DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo - Class in org.springframework.kafka.listener: Headers for data relative to the exception thrown.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original - Class in org.springframework.kafka.listener: Headers for data relative to the original record.
DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo - Class in org.springframework.kafka.listener: Header names for exception headers.
DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd - Enum Class in org.springframework.kafka.listener: Bits representing which headers to add.
DeadLetterPublishingRecoverer.HeaderNames.Original - Class in org.springframework.kafka.listener: Header names for original record property headers.
DeadLetterPublishingRecoverer.SingleRecordHeader - Class in org.springframework.kafka.listener: A Header that indicates that this header should replace any existing headers with this name, rather than being appended to the headers, which is the normal behavior.
deadLetterPublishingRecovererFactory(DestinationTopicResolver) - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory: Create the DeadLetterPublishingRecovererFactory that will be used to create the DeadLetterPublishingRecoverer to forward the records to a given DestinationTopic.
DeadLetterPublishingRecovererFactory - Class in org.springframework.kafka.retrytopic: Creates and configures the DeadLetterPublishingRecoverer that will be used to forward the messages using the DestinationTopicResolver.
DeadLetterPublishingRecovererFactory(DestinationTopicResolver) - Constructor for class org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory
DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator - Interface in org.springframework.kafka.retrytopic: Implement this interface to create each DeadLetterPublishingRecoverer.
DEBUG - Enum constant in enum class org.springframework.kafka.KafkaException.Level: Debug.
DEBUG - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level: Debug.
decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>) - Method in class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer: Decorates the provided ConcurrentKafkaListenerContainerFactory.
decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration) - Method in class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer: Deprecated, for removal: This API element is subject to removal in a future version.
decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration) - Method in class org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer: Deprecated, for removal: This API element is subject to removal in a future version.
DEFAULT_ADMIN_TIMEOUT - Static variable in interface org.springframework.kafka.test.EmbeddedKafkaBroker
DEFAULT_ADMIN_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
DEFAULT_BACK_OFF - Static variable in class org.springframework.kafka.listener.SeekUtils: The default back off - a FixedBackOff with 0 interval and SeekUtils.DEFAULT_MAX_FAILURES - 1 retry attempts.
DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper: Default header name for type information.
DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.config.StreamsBuilderFactoryBean: The default Duration of 10 seconds for close timeout.
DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.core.KafkaAdmin: The default close timeout duration as 10 seconds.
DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.core.ProducerFactoryUtils: The default close timeout (5 seconds).
DEFAULT_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper: Default header name for container object contents type information.
DEFAULT_DLT_HANDLER - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConfigurer: The default method to handle messages in the DLT.
DEFAULT_DLT_SUFFIX - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants: Default suffix for dlt.
DEFAULT_HEADER_ATTEMPTS - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders: The default header for the attempts.
DEFAULT_HEADER_BACKOFF_TIMESTAMP - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders: The default header for the backoff due timestamp.
DEFAULT_HEADER_ORIGINAL_TIMESTAMP - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders: The default header for the original message's timestamp.
DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor: The bean name of the default KafkaListenerContainerFactory.
DEFAULT_KAFKA_TEMPLATE_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames: The bean name of the internally managed listener container factory.
DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper: Default header name for map key type information.
DEFAULT_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames: The bean name of the internally managed listener container factory.
DEFAULT_MAX_ATTEMPTS - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants: Default number of times the message processing should be attempted, including the first.
DEFAULT_MAX_CONTENT_LOGGED - Static variable in class org.springframework.kafka.support.LoggingProducerListener: Default max content logged.
DEFAULT_MAX_FAILURES - Static variable in class org.springframework.kafka.listener.SeekUtils: The number of times a topic/partition/offset can fail before being rejected.
DEFAULT_MONITOR_INTERVAL - Static variable in class org.springframework.kafka.listener.ContainerProperties: The default monitorInterval (s).
DEFAULT_NO_POLL_THRESHOLD - Static variable in class org.springframework.kafka.listener.ContainerProperties: The default noPollThreshold.
DEFAULT_PHASE - Static variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer: The default SmartLifecycle phase for listener containers 2147483547.
DEFAULT_PHYSICAL_CLOSE_TIMEOUT - Static variable in interface org.springframework.kafka.core.ProducerFactory: The default close timeout duration as 30 seconds.
DEFAULT_POLL_TIMEOUT - Static variable in interface org.springframework.kafka.core.KafkaOperations: Default timeout for KafkaOperations.receive(String, int, long).
DEFAULT_POLL_TIMEOUT - Static variable in class org.springframework.kafka.listener.ConsumerProperties: The default pollTimeout (ms).
DEFAULT_PORT - Static variable in class org.springframework.kafka.test.core.BrokerAddress
DEFAULT_RETRY_SUFFIX - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants: Default suffix for retry topics.
DEFAULT_RETRY_TOPIC_CONFIG_SUPPORT_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames: The bean name of an internally managed retry topic configuration support, if needed.
DEFAULT_SCHEDULER_WRAPPER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames: The bean name of the internally registered scheduler wrapper, if needed.
DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class org.springframework.kafka.listener.ContainerProperties: The default shutDownTimeout (ms).
DEFAULT_STREAMS_BUILDER_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration: The bean name for auto-configured default StreamsBuilderFactoryBean.
DEFAULT_STREAMS_CONFIG_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration: The bean name for the StreamsConfig to be used for the default StreamsBuilderFactoryBean bean definition.
DEFAULT_ZK_CONNECTION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
DEFAULT_ZK_SESSION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
DefaultAfterRollbackProcessor<K,V> - Class in org.springframework.kafka.listener: Default implementation of AfterRollbackProcessor.
DefaultAfterRollbackProcessor() - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the default recoverer which simply logs the record after 10 (maxFailures) have occurred for a topic/partition/offset.
DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>) - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the provided recoverer which will be called after 10 (maxFailures) have occurred for a topic/partition/offset.
DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, KafkaOperations<?, ?>, boolean) - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler, KafkaOperations<?, ?>, boolean) - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
DefaultAfterRollbackProcessor(BackOff) - Constructor for class org.springframework.kafka.listener.DefaultAfterRollbackProcessor: Construct an instance with the default recoverer which simply logs the record after the backOff returns STOP for a topic/partition/offset.
DefaultBackOffHandler - Class in org.springframework.kafka.listener: Default BackOffHandler; suspends the thread for the back off.
DefaultBackOffHandler() - Constructor for class org.springframework.kafka.listener.DefaultBackOffHandler
DefaultBatchToRecordAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: The default BatchToRecordAdapter implementation; if the supplied recoverer throws an exception, the batch will be aborted; otherwise the next record will be processed.
DefaultBatchToRecordAdapter() - Constructor for class org.springframework.kafka.listener.adapter.DefaultBatchToRecordAdapter: Construct an instance with the default recoverer which simply logs the failed record.
DefaultBatchToRecordAdapter(ConsumerRecordRecoverer) - Constructor for class org.springframework.kafka.listener.adapter.DefaultBatchToRecordAdapter: Construct an instance with the provided recoverer.
defaultBranch(Consumer<? super KStream<K, V>>) - Method in class org.springframework.kafka.support.KafkaStreamBrancher: Defines a default branch.
DefaultDestinationTopicProcessor - Class in org.springframework.kafka.retrytopic: Default implementation of the DestinationTopicProcessor interface.
DefaultDestinationTopicProcessor(DestinationTopicResolver) - Constructor for class org.springframework.kafka.retrytopic.DefaultDestinationTopicProcessor
DefaultDestinationTopicResolver - Class in org.springframework.kafka.retrytopic: Default implementation of the DestinationTopicResolver interface.
DefaultDestinationTopicResolver() - Constructor for class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver: Constructs an instance with a default clock.
DefaultDestinationTopicResolver(Clock) - Constructor for class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver: Constructs an instance with the given clock.
DefaultDestinationTopicResolver.DestinationTopicHolder - Class in org.springframework.kafka.retrytopic
DefaultErrorHandler - Class in org.springframework.kafka.listener: An error handler that, for record listeners, seeks to the current offset for each topic in the remaining records.
DefaultErrorHandler() - Constructor for class org.springframework.kafka.listener.DefaultErrorHandler: Construct an instance with the default recoverer which simply logs the record after 10 (maxFailures) have occurred for a topic/partition/offset, with the default back off (9 retries, no delay).
DefaultErrorHandler(ConsumerRecordRecoverer) - Constructor for class org.springframework.kafka.listener.DefaultErrorHandler: Construct an instance with the provided recoverer which will be called after 10 (maxFailures) have occurred for a topic/partition/offset.
DefaultErrorHandler(ConsumerRecordRecoverer, BackOff) - Constructor for class org.springframework.kafka.listener.DefaultErrorHandler: Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
DefaultErrorHandler(ConsumerRecordRecoverer, BackOff, BackOffHandler) - Constructor for class org.springframework.kafka.listener.DefaultErrorHandler: Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
DefaultErrorHandler(BackOff) - Constructor for class org.springframework.kafka.listener.DefaultErrorHandler: Construct an instance with the default recoverer which simply logs the record after the backOff returns STOP for a topic/partition/offset.
defaultFalse() - Method in class org.springframework.kafka.listener.ExceptionClassifier: By default, unmatched types classify as true.
defaultFalse(boolean) - Method in class org.springframework.kafka.listener.ExceptionClassifier: By default, unmatched types classify as true.
defaultFatalExceptionsList() - Static method in class org.springframework.kafka.listener.ExceptionClassifier: Return a list of the framework default fatal exceptions.
DefaultJackson2JavaTypeMapper - Class in org.springframework.kafka.support.mapping: Jackson 2 type mapper.
DefaultJackson2JavaTypeMapper() - Constructor for class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper
DefaultKafkaConsumerFactory<K,V> - Class in org.springframework.kafka.core: The ConsumerFactory implementation to produce new Consumer instances for provided Map configs and optional Deserializers on each ConsumerFactory.createConsumer() invocation.
DefaultKafkaConsumerFactory(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Construct a factory with the provided configuration.
DefaultKafkaConsumerFactory(Map<String, Object>, Supplier<Deserializer<K>>, Supplier<Deserializer<V>>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Construct a factory with the provided configuration and deserializer suppliers.
DefaultKafkaConsumerFactory(Map<String, Object>, Supplier<Deserializer<K>>, Supplier<Deserializer<V>>, boolean) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Construct a factory with the provided configuration and deserializer suppliers.
DefaultKafkaConsumerFactory(Map<String, Object>, Deserializer<K>, Deserializer<V>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Construct a factory with the provided configuration and deserializers.
DefaultKafkaConsumerFactory(Map<String, Object>, Deserializer<K>, Deserializer<V>, boolean) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Construct a factory with the provided configuration and deserializers.
DefaultKafkaConsumerFactory.ExtendedKafkaConsumer - Class in org.springframework.kafka.core
DefaultKafkaHeaderMapper - Class in org.springframework.kafka.support: Default header mapper for Apache Kafka.
DefaultKafkaHeaderMapper() - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Construct an instance with the default object mapper and default header patterns for outbound headers; all inbound headers are mapped.
DefaultKafkaHeaderMapper(ObjectMapper) - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Construct an instance with the provided object mapper and default header patterns for outbound headers; all inbound headers are mapped.
DefaultKafkaHeaderMapper(ObjectMapper, String...) - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Construct an instance with the provided object mapper and the provided header patterns for outbound headers; all inbound headers are mapped.
DefaultKafkaHeaderMapper(String...) - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Construct an instance with a default object mapper and the provided header patterns for outbound headers; all inbound headers are mapped.
DefaultKafkaHeaderMapper.NonTrustedHeaderType - Class in org.springframework.kafka.support: Represents a header that could not be decoded due to an untrusted type.
DefaultKafkaListenerObservationConvention() - Constructor for class org.springframework.kafka.support.micrometer.KafkaListenerObservation.DefaultKafkaListenerObservationConvention
DefaultKafkaProducerFactory<K,V> - Class in org.springframework.kafka.core: The ProducerFactory implementation for a singleton shared Producer instance.
DefaultKafkaProducerFactory(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory: Construct a factory with the provided configuration.
DefaultKafkaProducerFactory(Map<String, Object>, Supplier<Serializer<K>>, Supplier<Serializer<V>>) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory: Construct a factory with the provided configuration and Serializer Suppliers.
DefaultKafkaProducerFactory(Map<String, Object>, Supplier<Serializer<K>>, Supplier<Serializer<V>>, boolean) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory: Construct a factory with the provided configuration and Serializer Suppliers.
DefaultKafkaProducerFactory(Map<String, Object>, Serializer<K>, Serializer<V>) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory: Construct a factory with the provided configuration and Serializers.
DefaultKafkaProducerFactory(Map<String, Object>, Serializer<K>, Serializer<V>, boolean) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory: Construct a factory with the provided configuration and Serializers.
DefaultKafkaProducerFactory.CloseSafeProducer<K,V> - Class in org.springframework.kafka.core: A wrapper class for the delegate.
defaultKafkaStreamsBuilder(ObjectProvider<KafkaStreamsConfiguration>, ObjectProvider<StreamsBuilderFactoryBeanConfigurer>) - Method in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration: Bean for the default StreamsBuilderFactoryBean.
DefaultKafkaTemplateObservationConvention() - Constructor for class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
defaultPropertyOverrides() - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Return a Properties object equal to the default consumer property overrides.
DefaultTransactionIdSuffixStrategy - Class in org.springframework.kafka.core: The TransactionIdSuffixStrategy implementation for managing transactional producer suffixes.
DefaultTransactionIdSuffixStrategy(int) - Constructor for class org.springframework.kafka.core.DefaultTransactionIdSuffixStrategy: Construct a transaction id suffix strategy with the provided size of the cache.
delay() - Method in class org.springframework.kafka.retrytopic.DestinationTopic.Properties
delegate - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
delegateType - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
DelegatingByTopicDeserializer - Class in org.springframework.kafka.support.serializer: A Deserializer that delegates to other deserializers based on the topic name.
DelegatingByTopicDeserializer() - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer: Construct an instance that will be configured in DelegatingByTopicDeserializer.configure(Map, boolean) with consumer properties.
DelegatingByTopicDeserializer(Map<Pattern, Deserializer<?>>, Deserializer<?>) - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer: Construct an instance with the supplied mapping of topic name patterns to delegate deserializers.
DelegatingByTopicSerialization<T extends Closeable> - Class in org.springframework.kafka.support.serializer: Base class with common code for delegating by topic serialization.
DelegatingByTopicSerialization() - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
DelegatingByTopicSerialization(Map<Pattern, T>, T) - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
DelegatingByTopicSerializer - Class in org.springframework.kafka.support.serializer: A Serializer that delegates to other serializers based on a topic pattern.
DelegatingByTopicSerializer() - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicSerializer: Construct an instance that will be configured in DelegatingByTopicSerializer.configure(Map, boolean) with producer properties DelegatingByTopicSerialization.VALUE_SERIALIZATION_TOPIC_CONFIG and DelegatingByTopicSerialization.KEY_SERIALIZATION_TOPIC_CONFIG.
DelegatingByTopicSerializer(Map<Pattern, Serializer<?>>, Serializer<?>) - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTopicSerializer: Construct an instance with the supplied mapping of topic patterns to delegate serializers.
DelegatingByTypeSerializer - Class in org.springframework.kafka.support.serializer: Delegates to a serializer based on type.
DelegatingByTypeSerializer(Map<Class<?>, Serializer<?>>) - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTypeSerializer: Construct an instance with the map of delegates; keys matched exactly.
DelegatingByTypeSerializer(Map<Class<?>, Serializer<?>>, boolean) - Constructor for class org.springframework.kafka.support.serializer.DelegatingByTypeSerializer: Construct an instance with the map of delegates; keys matched exactly or if the target object is assignable to the key, depending on the assignable argument.
DelegatingDeserializer - Class in org.springframework.kafka.support.serializer: A Deserializer that delegates to other deserializers based on a serialization selector header.
DelegatingDeserializer() - Constructor for class org.springframework.kafka.support.serializer.DelegatingDeserializer: Construct an instance that will be configured in DelegatingDeserializer.configure(Map, boolean) with consumer properties DelegatingSerializer.KEY_SERIALIZATION_SELECTOR_CONFIG and DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG.
DelegatingDeserializer(Map<String, Deserializer<?>>) - Constructor for class org.springframework.kafka.support.serializer.DelegatingDeserializer: Construct an instance with the supplied mapping of selectors to delegate deserializers.
DelegatingInvocableHandler - Class in org.springframework.kafka.listener.adapter: Delegates to an InvocableHandlerMethod based on the message payload type.
DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator) - Constructor for class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler: Construct an instance with the supplied handlers for the bean.
DelegatingMessageListener<T> - Interface in org.springframework.kafka.listener: Classes implementing this interface allow containers to determine the type of the ultimate listener.
DelegatingSerializer - Class in org.springframework.kafka.support.serializer: A Serializer that delegates to other serializers based on a serialization selector header.
DelegatingSerializer() - Constructor for class org.springframework.kafka.support.serializer.DelegatingSerializer: Construct an instance that will be configured in DelegatingSerializer.configure(Map, boolean) with producer properties DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG and DelegatingSerializer.KEY_SERIALIZATION_SELECTOR_CONFIG.
DelegatingSerializer(Map<String, Serializer<?>>) - Constructor for class org.springframework.kafka.support.serializer.DelegatingSerializer: Construct an instance with the supplied mapping of selectors to delegate serializers.
DELIVERY_ATTEMPT - Static variable in class org.springframework.kafka.support.KafkaHeaders: For inbound messages, when container retries are enabled the delivery attempt.
deliveryAttempt(TopicPartitionOffset) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
deliveryAttempt(TopicPartitionOffset) - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
deliveryAttempt(TopicPartitionOffset) - Method in interface org.springframework.kafka.listener.DeliveryAttemptAware: Return the next delivery attempt for the topic/partition/offset.
deliveryAttempt(TopicPartitionOffset) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
DeliveryAttemptAware - Interface in org.springframework.kafka.listener: A component implementing this interface can provide the next delivery attempt.
deliveryAttemptHeader() - Method in interface org.springframework.kafka.listener.CommonErrorHandler: Return true if this error handler supports delivery attempts headers.
deliveryAttemptHeader() - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
deliveryAttemptHeader() - Method in class org.springframework.kafka.listener.DefaultErrorHandler
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
describeTopics(String...) - Method in class org.springframework.kafka.core.KafkaAdmin
describeTopics(String...) - Method in interface org.springframework.kafka.core.KafkaAdminOperations: Obtain TopicDescriptions for these topics.
deserializationException(Headers, byte[], Exception, boolean) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils: Populate the record headers with a serialized DeserializationException.
DeserializationException - Exception in org.springframework.kafka.support.serializer: Exception returned in the consumer record value or key when a deserialization failure occurs.
DeserializationException(String, byte[], boolean, Throwable) - Constructor for exception org.springframework.kafka.support.serializer.DeserializationException: Construct an instance with the provided properties.
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.RetryingDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
deserialize(String, Headers, byte[]) - Method in class org.springframework.kafka.support.serializer.RetryingDeserializer
deserialize(String, Headers, ByteBuffer) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
deserialize(String, Headers, ByteBuffer) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
deserialize(String, Headers, ByteBuffer) - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
deserialize(String, Headers, ByteBuffer) - Method in class org.springframework.kafka.support.serializer.RetryingDeserializer
deserializer() - Method in class org.springframework.kafka.support.serializer.JsonSerde
deserializer() - Method in class org.springframework.kafka.support.serializer.ToFromStringSerde
DESERIALIZER_EXCEPTION_HEADER_PREFIX - Static variable in class org.springframework.kafka.support.KafkaUtils: Header name for deserialization exceptions.
DESERIALIZER_EXCEPTION_HEADER_PREFIX - Static variable in class org.springframework.kafka.support.serializer.SerializationUtils: Header name for deserialization exceptions.
DESTINATION_TOPIC_RESOLVER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames: The bean name of the internally managed destination topic resolver.
destinationsByTopicMap - Variable in class org.springframework.kafka.retrytopic.DestinationTopicProcessor.Context
DestinationTopic - Class in org.springframework.kafka.retrytopic: Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.
DestinationTopic(String, DestinationTopic.Properties) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopic
DestinationTopic(String, DestinationTopic, String, DestinationTopic.Type) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopic
DestinationTopic.Properties - Class in org.springframework.kafka.retrytopic
DestinationTopicContainer - Interface in org.springframework.kafka.retrytopic: Provides methods to store and retrieve DestinationTopic instances.
destinationTopicProcessor(DestinationTopicResolver) - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory: Create the DestinationTopicProcessor that will be used to process the DestinationTopic instances and store them in the provided DestinationTopicResolver.
DestinationTopicProcessor - Interface in org.springframework.kafka.retrytopic: The DestinationTopicProcessor creates and registers the DestinationTopic instances in the provided DestinationTopicProcessor.Context, also providing callback interfaces to be called upon the context properties.
DestinationTopicProcessor.Context - Class in org.springframework.kafka.retrytopic
DestinationTopicPropertiesFactory - Class in org.springframework.kafka.retrytopic: Creates a list of DestinationTopic.Properties based on the provided configurations.
DestinationTopicPropertiesFactory(String, String, List<Long>, BinaryExceptionClassifier, int, KafkaOperations<?, ?>, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory: Construct an instance with the provided properties.
DestinationTopicPropertiesFactory(String, String, List<Long>, BinaryExceptionClassifier, int, KafkaOperations<?, ?>, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long, Map<String, Set<Class<? extends Throwable>>>) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory: Construct an instance with the provided properties.
DestinationTopicPropertiesFactory.DestinationTopicSuffixes - Class in org.springframework.kafka.retrytopic
destinationTopicResolver() - Method in class org.springframework.kafka.retrytopic.RetryTopicComponentFactory: Create the instance of DestinationTopicResolver that will be used to store the DestinationTopic instance and resolve which a given record should be forwarded to.
destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport: Return a global DestinationTopicResolver for resolving the DestinationTopic to which a given ConsumerRecord should be sent for retry.
DestinationTopicResolver - Interface in org.springframework.kafka.retrytopic: Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.
DestinationTopicSuffixes(String, String) - Constructor for class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory.DestinationTopicSuffixes
destroy() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
destroy() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
destroy() - Method in class org.springframework.kafka.core.KafkaTemplate
destroy() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
destroy() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
destroy() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
destroy() - Method in class org.springframework.kafka.retrytopic.RetryTopicSchedulerWrapper
destroy() - Method in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
destroy() - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder: Remove the timers.
destroy() - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker
destroy() - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
destroy() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
determineInferredType(Method) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter: Subclasses can override this method to use a different mechanism to determine the target type of the payload conversion.
determineListenerType(Object) - Static method in class org.springframework.kafka.listener.ListenerUtils: Determine the type of the listener.
determineSendTimeout(Map<String, Object>, long, long) - Static method in class org.springframework.kafka.support.KafkaUtils: Return the timeout to use when sending records.
determineSendTimeout(KafkaOperations<?, ?>) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Determine the send timeout based on the template's producer factory and DeadLetterPublishingRecoverer.setWaitForSendResultTimeout(Duration).
DLT_EXCEPTION_CAUSE_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception cause class name for a record published sent to a dead-letter topic.
DLT_EXCEPTION_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception class name for a record published sent to a dead-letter topic.
DLT_EXCEPTION_MESSAGE - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception message for a record published to a dead-letter topic.
DLT_EXCEPTION_STACKTRACE - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception stack trace for a record published to a dead-letter topic.
DLT_KEY_EXCEPTION_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception class name for a record published sent to a dead-letter topic with a key deserialization exception.
DLT_KEY_EXCEPTION_MESSAGE - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception message for a record published to a dead-letter topic with a key deserialization exception.
DLT_KEY_EXCEPTION_STACKTRACE - Static variable in class org.springframework.kafka.support.KafkaHeaders: Exception stack trace for a record published to a dead-letter topic with a key deserialization exception.
DLT_ORIGINAL_CONSUMER_GROUP - Static variable in class org.springframework.kafka.support.KafkaHeaders: Consumer group that failed to consumer a record published to a dead-letter topic.
DLT_ORIGINAL_OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders: Original offset for a record published to a dead-letter topic.
DLT_ORIGINAL_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders: Original partition for a record published to a dead-letter topic.
DLT_ORIGINAL_TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders: Original timestamp for a record published to a dead-letter topic.
DLT_ORIGINAL_TIMESTAMP_TYPE - Static variable in class org.springframework.kafka.support.KafkaHeaders: Original timestamp type for a record published to a dead-letter topic.
DLT_ORIGINAL_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders: Original topic for a record published to a dead-letter topic.
DltHandler - Annotation Interface in org.springframework.kafka.annotation: Annotation to determine the method that should process the DLT topic message.
dltHandlerMethod(String, String) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure a DLT handler method.
dltHandlerMethod(EndpointHandlerMethod) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure a DLT handler method.
dltProcessingFailureStrategy(DltStrategy) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure the DltStrategy.
dltRoutingRules(Map<String, Set<Class<? extends Throwable>>>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure to set DLT routing rules causing the message to be redirected to the custom DLT when the configured exception has been thrown during message processing.
dltStrategy() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic: Whether or not create a DLT, and redeliver to the DLT if delivery fails or just give up.
DltStrategy - Enum Class in org.springframework.kafka.retrytopic: Strategies for handling DLT processing.
dltSuffix(String) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure the suffix to add to the DLT topic.
dltTopicSuffix() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic: The suffix that will be appended to the main topic in order to generate the dlt topic.
doBegin(Object, TransactionDefinition) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doCleanupAfterCompletion(Object) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doCommit(DefaultTransactionStatus) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doCreateManager(ListenerContainerRegistry) - Method in class org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
doCreateManager(ListenerContainerRegistry) - Method in class org.springframework.kafka.listener.ContainerPartitionPausingBackOffManagerFactory
doGetTransaction() - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doHandle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.FailedBatchProcessor
doInKafka(Producer<K, V>) - Method in interface org.springframework.kafka.core.KafkaOperations.ProducerCallback
doInOperations(KafkaOperations<K, V>) - Method in interface org.springframework.kafka.core.KafkaOperations.OperationsCallback
doInvoke(Object...) - Method in class org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod
doNotAutoCreateRetryTopics() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure the topic creation behavior to NOT auto create topics.
doNotConfigureDlt() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure the DltStrategy to DltStrategy.NO_DLT.
doNotRetryOnDltFailure() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder: Configure the DltStrategy to DltStrategy.FAIL_ON_ERROR.
dontRemoveTypeHeaders() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer: Don't remove type information headers.
dontRemoveTypeHeaders() - Method in class org.springframework.kafka.support.serializer.JsonSerde: Don't remove type information headers after deserialization.
doOnConsumer(Function<Consumer<K, V>, ? extends T>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
doOnProducer(Function<Producer<K, V>, ? extends T>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
doResume(Object, Object) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doRollback(DefaultTransactionStatus) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doSeeks(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, Exception, boolean, BiPredicate<ConsumerRecord<?, ?>, Exception>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils: Seek records to earliest position, optionally skipping the first.
doSeeks(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, Exception, boolean, RecoveryStrategy, MessageListenerContainer, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils: Seek records to earliest position, optionally skipping the first.
doSeeksToBegin(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils: Seek records to begin position, optionally skipping the first.
doSend(ProducerRecord<K, V>, Observation) - Method in class org.springframework.kafka.core.KafkaTemplate: Send the producer record.
doSetRollbackOnly(DefaultTransactionStatus) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doStart() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
doStart() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
doStart() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
doStop(Runnable) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
doStop(Runnable, boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Stop the container normally or abnormally.
doStop(Runnable, boolean) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
doStop(Runnable, boolean) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
doSuspend(Object) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
doWithAdmin(Consumer<AdminClient>) - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker: Create an AdminClient; invoke the callback and reliably close the admin.
doWithAdmin(Consumer<AdminClient>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: Create an AdminClient; invoke the callback and reliably close the admin.
doWithAdminFunction(Function<AdminClient, T>) - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker: Create an AdminClient; invoke the callback and reliably close the admin.
doWithAdminFunction(Function<AdminClient, T>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: Create an AdminClient; invoke the callback and reliably close the admin.

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