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 All Packages
All Classes All Packages
All Classes All Packages
A
- abortTransaction() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- AbstractConsumerSeekAware - Class in org.springframework.kafka.listener
-
Manages the
ConsumerSeekAware.ConsumerSeekCallback
s for the listener. - AbstractConsumerSeekAware() - Constructor for class org.springframework.kafka.listener.AbstractConsumerSeekAware
- AbstractDelegatingMessageListenerAdapter<T> - Class in org.springframework.kafka.listener.adapter
-
Top level class for all listener adapters.
- AbstractDelegatingMessageListenerAdapter(T) - Constructor for class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- AbstractFilteringMessageListener<K,V,T> - Class in org.springframework.kafka.listener.adapter
-
An abstract message listener adapter that implements record filter logic via a
RecordFilterStrategy
. - AbstractFilteringMessageListener(T, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener
- AbstractJavaTypeMapper - Class in org.springframework.kafka.support.converter
-
Abstract type mapper.
- AbstractJavaTypeMapper() - Constructor for class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- AbstractKafkaHeaderMapper - Class in org.springframework.kafka.support
-
Base for Kafka header mappers.
- AbstractKafkaHeaderMapper(String...) - Constructor for class org.springframework.kafka.support.AbstractKafkaHeaderMapper
- AbstractKafkaHeaderMapper.HeaderMatcher - Interface in org.springframework.kafka.support
-
A matcher for headers.
- AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher - Class in org.springframework.kafka.support
-
A matcher that never matches a set of headers.
- AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher - Class in org.springframework.kafka.support
-
A pattern-based header matcher that matches if the specified header matches the specified simple pattern.
- AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V> - Class in org.springframework.kafka.config
-
Base
KafkaListenerContainerFactory
for Spring's base container implementation. - AbstractKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- AbstractKafkaListenerEndpoint<K,V> - Class in org.springframework.kafka.config
-
Base model for a Kafka listener endpoint.
- AbstractKafkaListenerEndpoint() - Constructor for class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- AbstractMessageListenerContainer<K,V> - Class in org.springframework.kafka.listener
-
The base implementation for the
MessageListenerContainer
. - AbstractMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Construct an instance with the provided factory and properties.
- AbstractRetryingMessageListenerAdapter<K,V,T> - Class in org.springframework.kafka.listener.adapter
-
Base class for retrying message listener adapters.
- AbstractRetryingMessageListenerAdapter(T, RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
-
Construct an instance with the supplied retry template.
- AbstractRetryingMessageListenerAdapter(T, RetryTemplate, RecoveryCallback<? extends Object>) - Constructor for class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
-
Construct an instance with the supplied template and callback.
- ABSwitchCluster - Class in org.springframework.kafka.core
-
A
Supplier
for bootstrap servers that can toggle between 2 lists of servers. - ABSwitchCluster(String, String) - Constructor for class org.springframework.kafka.core.ABSwitchCluster
-
Construct an instance with primary and secondary bootstrap servers.
- accept(ConsumerRecord<?, ?>, Exception) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
- acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
BiConsumer.accept(Object, Object)
with the arguments if the condition is true. - acceptIfCondition(boolean, T, Consumer<T>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if the condition is true. - acceptIfHasText(String, Consumer<String>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if it is not null or empty. - acceptIfHasText(T, String, BiConsumer<T, String>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
BiConsumer.accept(Object, Object)
with the arguments if the value argument is not null or empty. - acceptIfNotEmpty(List<T>, Consumer<List<T>>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if it is not null or empty. - acceptIfNotEmpty(T[], Consumer<T[]>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if it is not null or empty. - acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
BiConsumer.accept(Object, Object)
with the arguments if the t2 argument is not null. - acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.kafka.support.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if it is not null. - acknowledge() - Method in interface org.springframework.kafka.support.Acknowledgment
-
Invoked when the record or batch for which the acknowledgment has been created has been processed.
- ACKNOWLEDGING - org.springframework.kafka.listener.ListenerType
-
Acknowledging.
- ACKNOWLEDGING_CONSUMER_AWARE - org.springframework.kafka.listener.ListenerType
-
Acknowledging and consumer aware.
- AcknowledgingConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
- AcknowledgingMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
- Acknowledgment - Interface in org.springframework.kafka.support
-
Handle for acknowledging the processing of a
ConsumerRecord
. - ACKNOWLEDGMENT - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for the
Acknowledgment
. - adapt(List<Message<?>>, List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>, BatchToRecordAdapter.Callback<K, V>) - Method in interface org.springframework.kafka.listener.adapter.BatchToRecordAdapter
-
Adapt the list and invoke the callback for each message.
- adapt(List<Message<?>>, List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>, BatchToRecordAdapter.Callback<K, V>) - Method in class org.springframework.kafka.listener.adapter.DefaultBatchToRecordAdapter
- AdapterUtils - Class in org.springframework.kafka.listener.adapter
-
Utilities for listener adapters.
- ADD_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonSerializer
-
Kafka config property for disabling adding type headers.
- ADD_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Kafka config property for enabling/disabling adding type headers.
- addDelegate(String, Deserializer<?>) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
- addDelegate(String, Serializer<?>) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
- addDelegate(ProducerListener<K, V>) - Method in class org.springframework.kafka.support.CompositeProducerListener
- addHeader(Headers, String, Class<?>) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- additionalHeaders() - Method in interface org.springframework.kafka.listener.adapter.ReplyHeadersConfigurer
-
A map of additional headers to add to the reply message.
- addKafkaStreamsCustomizers(List<KafkaStreamsCustomizer>) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsCustomizer
- addKafkaStreamsCustomizers(KafkaStreamsInfrastructureCustomizer...) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
-
Add customizers.
- addListener(int, ConsumerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Add a listener at a specific index.
- addListener(int, ConsumerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Add a listener at a specific index.
- addListener(int, ProducerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Add a listener at a specific index.
- addListener(int, ProducerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory
-
Add a listener at a specific index.
- addListener(StreamsBuilderFactoryBean.Listener) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Add a
StreamsBuilderFactoryBean.Listener
which will be called after starting and stopping the streams. - addListener(ConsumerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Add a listener.
- addListener(ConsumerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Add a listener.
- addListener(ProducerFactory.Listener<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Add a listener.
- addListener(ProducerFactory.Listener<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory
-
Add a listener.
- addMatchers(AbstractKafkaHeaderMapper.HeaderMatcher...) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Subclasses can invoke this to add custom
AbstractKafkaHeaderMapper.HeaderMatcher
s. - addNotRetryableException(Class<? extends Exception>) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Deprecated.
- addNotRetryableExceptions(Class<? extends Exception>...) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Add exception types to the default list.
- addPostProcessor(ConsumerPostProcessor<K, V>) - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Add a post processor.
- addPostProcessor(ConsumerPostProcessor<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- addPostProcessor(ProducerPostProcessor<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- addPostProcessor(ProducerPostProcessor<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory
-
Add a post processor.
- addTopics(String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Add topics to the existing broker(s) using the configured number of partitions.
- addTopics(NewTopic...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Add topics to the existing broker(s).
- addTopicsWithResults(String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Add topics to the existing broker(s) using the configured number of partitions.
- addTopicsWithResults(NewTopic...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Add topics to the existing broker(s) and returning a map of results.
- addToStringClasses(String...) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Add class names that the outbound mapper should perform toString() operations on before mapping.
- addTrustedPackages(String...) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
-
Specify a set of packages to trust during deserialization.
- addTrustedPackages(String...) - Method in interface org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
- addTrustedPackages(String...) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Add packages to the trusted packages list (default
java.util, java.lang
) used when constructing objects from JSON. - addTrustedPackages(String...) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Add trusted packages for deserialization.
- addTypeInfo - Variable in class org.springframework.kafka.support.serializer.JsonSerializer
- adjustLogLevels(String, List<Class<?>>, List<String>, Level) - Static method in class org.springframework.kafka.test.utils.JUnitUtils
- after() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
- afterAll(ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
- afterAll(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition
- afterEach(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition
- afterPropertiesSet() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- afterPropertiesSet() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- afterPropertiesSet() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
- afterPropertiesSet() - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
- afterPropertiesSet() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- afterPropertiesSet() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- AfterRollbackProcessor<K,V> - Interface in org.springframework.kafka.listener
-
Invoked by a listener container with remaining, unprocessed, records (including the failed record).
- afterSingletonsInstantiated() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- afterSingletonsInstantiated() - Method in class org.springframework.kafka.core.KafkaAdmin
- afterSingletonsInstantiated() - Method in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
- AGGREGATED_RESULTS_TOPIC - Static variable in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
-
Pseudo topic name for the "outer"
ConsumerRecord
that has the aggregated results in its value after a normal release by the release strategy. - AggregatingReplyingKafkaTemplate<K,V,R> - Class in org.springframework.kafka.requestreply
-
A replying template that aggregates multiple replies with the same correlation id.
- AggregatingReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, Collection<ConsumerRecord<K, R>>>, BiPredicate<List<ConsumerRecord<K, R>>, Boolean>) - Constructor for class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
-
Construct an instance using the provided parameter arguments.
- ALPHA - org.springframework.kafka.listener.ContainerProperties.EOSMode
-
'transactional.id' fencing (0.11 - 2.4 brokers).
- ALWAYS - org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Always commit the current offset during partition assignment.
- apply(Statement, FrameworkMethod, Object) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
- asProperties() - Method in class org.springframework.kafka.config.KafkaStreamsConfiguration
-
Return the configuration map as a
Properties
. - assignment() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- assignReplicas(int, List<Integer>) - Method in class org.springframework.kafka.config.TopicBuilder
-
Add an individual replica assignment.
- autoStartup() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
Set to true or false, to override the default setting in the container factory.
B
- BATCH - org.springframework.kafka.listener.ContainerProperties.AckMode
-
Commit whatever has already been processed before the next poll.
- BATCH_CONVERTED_HEADERS - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for a list of Maps of converted native Kafka headers.
- BatchAcknowledgingConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
- BatchAcknowledgingMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
- BatchConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
- BatchErrorHandler - Interface in org.springframework.kafka.listener
-
Handles errors thrown during the execution of a
BatchMessageListener
. - BatchListenerFailedException - Exception in org.springframework.kafka.listener
-
An exception thrown by user code to inform the framework which record in a batch has failed.
- BatchListenerFailedException(String, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException
-
Construct an instance with the provided properties.
- BatchListenerFailedException(String, Throwable, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException
-
Construct an instance with the provided properties.
- BatchListenerFailedException(String, Throwable, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException
-
Construct an instance with the provided properties.
- BatchListenerFailedException(String, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException
-
Construct an instance with the provided properties.
- BatchLoggingErrorHandler - Class in org.springframework.kafka.listener
-
Simple handler that invokes a
LoggingErrorHandler
for each record. - BatchLoggingErrorHandler() - Constructor for class org.springframework.kafka.listener.BatchLoggingErrorHandler
- BatchMessageConverter - Interface in org.springframework.kafka.support.converter
-
A Kafka-specific
Message
converter strategy. - BatchMessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
- BatchMessagingMessageConverter - Class in org.springframework.kafka.support.converter
-
A Messaging
MessageConverter
implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload. - BatchMessagingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Create an instance that does not convert the record values.
- BatchMessagingMessageConverter(RecordMessageConverter) - Constructor for class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Create an instance that converts record values using the supplied converter.
- BatchMessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
-
A
MessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive batches of messages. - BatchMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Create an instance with the provided parameters.
- BatchMessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - Constructor for class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Create an instance with the provided parameters.
- BatchToRecordAdapter<K,V> - Interface in org.springframework.kafka.listener.adapter
-
An adapter that adapts a batch listener to a record listener method.
- BatchToRecordAdapter.Callback<K,V> - Interface in org.springframework.kafka.listener.adapter
-
A callback for each message.
- BEAN_NAME - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
- beanRef() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
A pseudo bean name used in SpEL expressions within this annotation to reference the current bean within which this listener is defined.
- before() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
- beforeAll(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition
- beforeEach(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition
- BEGINNING - org.springframework.kafka.support.TopicPartitionOffset.SeekPosition
-
Seek to the beginning.
- beginningOffsets(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- beginTransaction() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- BETA - org.springframework.kafka.listener.ContainerProperties.EOSMode
-
fetch-offset-request fencing (2.5+ brokers).
- bootstrapServersProperty() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
The property name to set with the bootstrap server addresses instead of the default "spring.embedded.kafka.brokers".
- bounce(BrokerAddress) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- branch(Predicate<? super K, ? super V>, Consumer<? super KStream<K, V>>) - Method in class org.springframework.kafka.support.KafkaStreamBrancher
-
Defines a new branch.
- BROKER_LIST_PROPERTY - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set the value of this property to a property name that should be set to the list of embedded broker addresses instead of "spring.embedded.kafka.brokers".
- BrokerAddress - Class in org.springframework.kafka.test.core
-
Encapsulates the address of a Kafka broker.
- BrokerAddress(String) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
- BrokerAddress(String, int) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
- BrokerAddress(BrokerEndPoint) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
- brokerListProperty(String) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set the system property with this name to the list of broker addresses.
- brokerProperties() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Properties in form key=value that should be added to the broker config before runs.
- brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Specify the properties to configure Kafka Broker before start, e.g.
- brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Specify the properties to configure Kafka Broker before start, e.g.
- brokerPropertiesLocation() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Spring
Resource
url specifying the location of properties that should be added to the broker config. - brokerProperty(String, Object) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Specify a broker property.
- brokerProperty(String, Object) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Specify a broker property.
- build() - Method in class org.springframework.kafka.config.TopicBuilder
- buildConsumerRecordMetadata(Object) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils
-
Build a
ConsumerRecordMetadata
from data which must be aConsumerRecord
. - buildConsumerRecordMetadataFromArray(Object...) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils
-
Build a
ConsumerRecordMetadata
from the firstConsumerRecord
in data, if any. - ByteArrayJsonMessageConverter - Class in org.springframework.kafka.support.converter
-
JSON Message converter -
byte[]
on output, String, Bytes, or byte[] on input. - ByteArrayJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter
- ByteArrayJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter
- BytesJsonMessageConverter - Class in org.springframework.kafka.support.converter
-
JSON Message converter -
Bytes
on output, String, Bytes, or byte[] on input. - BytesJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.BytesJsonMessageConverter
- BytesJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.BytesJsonMessageConverter
C
- categories() - Method in annotation type 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
-
A
ChainedTransactionManager
that has exactly oneKafkaAwareTransactionManager
in the chain. - ChainedKafkaTransactionManager(PlatformTransactionManager...) - Constructor for class org.springframework.kafka.transaction.ChainedKafkaTransactionManager
-
Construct an instance with the provided
PlatformTransactionManager
s. - checkBootstrap(Map<String, Object>) - Method in class org.springframework.kafka.core.KafkaResourceFactory
-
Enhance the properties by calling the
KafkaResourceFactory.setBootstrapServersSupplier(Supplier)
amd 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. - checkGroupId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- checkTopics() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- classes() - Method in annotation type org.springframework.kafka.test.condition.LogLevels
-
Classes representing Log4j categories to change.
- ClassMapper - Interface in org.springframework.kafka.support.converter
-
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.FailedRecordProcessor
- clearThreadState() - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Optional method to clear thread state; will be called just before a consumer thread terminates.
- clearThreadState() - Method in class org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler
- clearTransactionIdSuffix() - Static method in class org.springframework.kafka.support.TransactionSupport
- clientIdPrefix() - Method in annotation type 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
- close() - Method in class org.springframework.kafka.streams.messaging.MessagingTransformer
- 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 class org.springframework.kafka.core.DefaultKafkaProducerFactory
- closeProducerFor(String) - Method in interface org.springframework.kafka.core.ProducerFactory
-
Remove the specified producer from the cache and close it.
- 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.
- 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
- 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.
- compact() - Method in class org.springframework.kafka.config.TopicBuilder
-
Set the
TopicConfig.CLEANUP_POLICY_CONFIG
toTopicConfig.CLEANUP_POLICY_COMPACT
. - CompositeKafkaStreamsCustomizer - Class in org.springframework.kafka.config
-
Composite
KafkaStreamsCustomizer
customizesKafkaStreams
by delegating to a list of providedKafkaStreamsCustomizer
. - 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
customizesKafkaStreams
by delegating to a list of providedKafkaStreamsInfrastructureCustomizer
. - CompositeKafkaStreamsInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer...) - Constructor for class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
-
Construct an instance with the provided customizers.
- 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 moreRecordInterceptor
in order. - CompositeRecordInterceptor(RecordInterceptor<K, V>...) - Constructor for class org.springframework.kafka.listener.CompositeRecordInterceptor
- concurrency() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
Override the container factory's
concurrency
setting for this listener. - ConcurrentKafkaListenerContainerFactory<K,V> - Class in org.springframework.kafka.config
-
A
KafkaListenerContainerFactory
implementation to build aConcurrentMessageListenerContainer
. - ConcurrentKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
- ConcurrentMessageListenerContainer<K,V> - Class in org.springframework.kafka.listener
-
Creates 1 or more
KafkaMessageListenerContainer
s based onconcurrency
. - ConcurrentMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
Construct an instance with the supplied configuration properties.
- 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, ?>, 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.StreamsBuilderFactoryBeanCustomizer
-
Configure the factory bean.
- configureBuilder(StreamsBuilder) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsInfrastructureCustomizer
- configureBuilder(StreamsBuilder) - Method in interface org.springframework.kafka.config.KafkaStreamsInfrastructureCustomizer
-
Configure the builder.
- configureKafkaListeners(KafkaListenerEndpointRegistrar) - Method in interface org.springframework.kafka.annotation.KafkaListenerConfigurer
-
Callback allowing a
KafkaListenerEndpointRegistry
and specificKafkaListenerEndpoint
instances to be registered against the givenKafkaListenerEndpointRegistrar
. - 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
- 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.
- consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Subscribe a consumer to one 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 - 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
-
An error handler that has access to the consumer, for example to adjust offsets after an error.
- ConsumerAwareErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler that has access to the consumer, for example to adjust offsets after an error.
- ConsumerAwareListenerErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler that has access to the consumer, for example to adjust offsets after an error.
- 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.
- 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.
- 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, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerPausedEvent
-
Deprecated.
- 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.
- ConsumerResumedEvent(Object, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerResumedEvent
-
Deprecated.
- 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) - Constructor for class org.springframework.kafka.event.ConsumerStoppedEvent
-
Deprecated.
- ConsumerStoppedEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ConsumerStoppedEvent
-
Construct an instance with the provided source and container.
- 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.
- ConsumerStoppingEvent(Object, Consumer<?, ?>, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ConsumerStoppingEvent
-
Deprecated.
- ContainerAwareBatchErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler that has access to the batch of records from the last poll the consumer, and the container.
- ContainerAwareErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler that has access to the unprocessed records from the last poll (including the failed record), the consumer, and the container.
- 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() - Method in annotation type 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() - Method in annotation type 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>
. - 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 in org.springframework.kafka.listener
-
The offset commit behavior enumeration.
- ContainerProperties.AssignmentCommitOption - Enum in org.springframework.kafka.listener
-
Offset commit behavior during assignment.
- ContainerProperties.EOSMode - Enum 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) - Constructor for class org.springframework.kafka.event.ContainerStoppedEvent
-
Deprecated.
- ContainerStoppedEvent(Object, Object) - Constructor for class org.springframework.kafka.event.ContainerStoppedEvent
-
Construct an instance with the provided source and container.
- ContainerStoppingBatchErrorHandler - Class in org.springframework.kafka.listener
-
A container error handler that stops the container after an exception is thrown by the listener.
- ContainerStoppingBatchErrorHandler() - Constructor for class org.springframework.kafka.listener.ContainerStoppingBatchErrorHandler
-
Construct an instance with a
SimpleAsyncTaskExecutor
. - ContainerStoppingBatchErrorHandler(Executor) - Constructor for class org.springframework.kafka.listener.ContainerStoppingBatchErrorHandler
-
Construct an instance with the provided
Executor
. - ContainerStoppingErrorHandler - Class in org.springframework.kafka.listener
-
A container error handler that stops the container after an exception is thrown by the listener.
- ContainerStoppingErrorHandler() - Constructor for class org.springframework.kafka.listener.ContainerStoppingErrorHandler
- ContainerStoppingErrorHandler(Executor) - Constructor for class org.springframework.kafka.listener.ContainerStoppingErrorHandler
- ContainerTestUtils - Class in org.springframework.kafka.test.utils
-
Utilities for testing listener containers.
- CONTEXT_ACKNOWLEDGMENT - Static variable in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
RetryContext
attribute key for an acknowledgment if the listener is capable of acknowledging. - CONTEXT_CONSUMER - Static variable in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
RetryContext
attribute key for the consumer if the listener is consumer-aware. - CONTEXT_RECORD - Static variable in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
RetryContext
attribute key for the record. - controlledShutdown() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
- ConversionException - Exception in org.springframework.kafka.support.converter
-
Exception for conversions.
- ConversionException(String, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
- convert(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Convert the record value.
- 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
- 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() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
- COUNT - org.springframework.kafka.listener.ContainerProperties.AckMode
-
Commit pending updates after
ackCount
has been exceeded. - COUNT_TIME - org.springframework.kafka.listener.ContainerProperties.AckMode
- 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, 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
- 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
- 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
- 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
- createKafkaConsumer(String, String, String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Deprecated.
- 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
-
Create a
MessageListenerContainer
for the givenKafkaListenerEndpoint
. - createListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
Create and start a new
MessageListenerContainer
using the specified factory. - 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
- createNonTransactionalProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- createNonTransactionalProducer() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Create a non-transactional producer.
- 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(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.
- createProducerRecord(ConsumerRecord<?, ?>, TopicPartition, Headers, byte[], boolean) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Subclasses can override this method to customize the producer record to send to the DLQ.
- 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
- 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 aDefaultKafkaProducerFactory.CloseSafeProducer
. - createTransactionalProducer(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- createTransactionalProducerForPartition() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- createTransactionalProducerForPartition(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- customize(KafkaStreams) - Method in class org.springframework.kafka.config.CompositeKafkaStreamsCustomizer
- customize(KafkaStreams) - Method in interface org.springframework.kafka.config.KafkaStreamsCustomizer
D
- DeadLetterPublishingRecoverer - Class in org.springframework.kafka.listener
-
A
ConsumerRecordRecoverer
that publishes a failed record to a dead-letter topic. - 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(KafkaTemplate<? extends Object, ? extends Object>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Deprecated.in favor of
DeadLetterPublishingRecoverer(KafkaOperations)
. - DeadLetterPublishingRecoverer(KafkaTemplate<? extends Object, ? extends Object>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Deprecated.
- DEBUG - org.springframework.kafka.KafkaException.Level
-
Debug.
- DEBUG - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Debug.
- DEFAULT_BACK_OFF - Static variable in class org.springframework.kafka.listener.SeekUtils
-
The default back off - a
FixedBackOff
with 0 interval andSeekUtils.DEFAULT_MAX_FAILURES
- 1 retry attempts. - DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Default header name for type information.
- DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
The default
Duration
of10 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.converter.AbstractJavaTypeMapper
-
Default header name for container object contents type information.
- DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
The bean name of the default
KafkaListenerContainerFactory
. - DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Default header name for map key type information.
- 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 class org.springframework.kafka.listener.ConsumerProperties
-
The default
pollTimeout
(ms). - DEFAULT_PORT - Static variable in class org.springframework.kafka.test.core.BrokerAddress
- 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 defaultStreamsBuilderFactoryBean
bean definition. - DEFAULT_ZK_CONNECTION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
- DEFAULT_ZK_SESSION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
- 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(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.
- 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.
- DefaultJackson2JavaTypeMapper - Class in org.springframework.kafka.support.converter
-
Jackson 2 type mapper.
- DefaultJackson2JavaTypeMapper() - Constructor for class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- DefaultKafkaConsumerFactory<K,V> - Class in org.springframework.kafka.core
-
The
ConsumerFactory
implementation to produce newConsumer
instances for providedMap
configs
and optionalDeserializer
s on eachConsumerFactory.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>, Deserializer<K>, Deserializer<V>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Construct a factory with the provided configuration and deserializers.
- 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.
- DefaultKafkaProducerFactory<K,V> - Class in org.springframework.kafka.core
- 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>, Serializer<K>, Serializer<V>) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Construct a factory with the provided configuration and
Serializer
s. - DefaultKafkaProducerFactory.CloseSafeProducer<K,V> - Class in org.springframework.kafka.core
-
A wrapper class for the delegate.
- defaultKafkaStreamsBuilder(ObjectProvider<KafkaStreamsConfiguration>, ObjectProvider<StreamsBuilderFactoryBeanCustomizer>) - Method in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration
- defaultPropertyOverrides() - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Return a
Properties
object equal to the default consumer property overrides. - delegate - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- delegateType - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- 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 propertiesDelegatingSerializer.KEY_SERIALIZATION_SELECTOR_CONFIG
andDelegatingSerializer.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>, Object, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Construct an instance with the supplied handlers for the bean.
- DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Construct an instance with the supplied handlers for the bean.
- DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory) - 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 propertiesDelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG
andDelegatingSerializer.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.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.
- 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
- 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.
- DeserializationException(String, Headers, byte[], boolean, Throwable) - Constructor for exception org.springframework.kafka.support.serializer.DeserializationException
-
Deprecated.Headers are not set during construction.
- 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.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
- deserializer() - Method in class org.springframework.kafka.support.serializer.JsonSerde
- deserializer() - Method in class org.springframework.kafka.support.serializer.ToFromStringSerde
- 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 class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- 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 class org.springframework.kafka.test.EmbeddedKafkaBroker
- 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
- 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_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.
- 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
- doGetTransaction() - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
- 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
- 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.
- doSend(ProducerRecord<K, V>) - 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) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- doStop(Runnable) - 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.EmbeddedKafkaBroker
-
Create an
AdminClient
; invoke the callback and reliably close the admin. - doWithAdminFunction(Function<AdminClient, T>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Create an
AdminClient
; invoke the callback and reliably close the admin.
E
- EmbeddedKafka - Annotation Type in org.springframework.kafka.test.context
-
Annotation that can be specified on a test class that runs Spring Kafka based tests.
- EmbeddedKafkaBroker - Class in org.springframework.kafka.test
-
An embedded Kafka Broker(s) and Zookeeper manager.
- EmbeddedKafkaBroker(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
- EmbeddedKafkaBroker(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Create embedded Kafka brokers listening on random ports.
- EmbeddedKafkaBroker(int, boolean, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Create embedded Kafka brokers.
- EmbeddedKafkaBroker.EmbeddedZookeeper - Class in org.springframework.kafka.test
-
Ported from scala to allow setting the port.
- EmbeddedKafkaCondition - Class in org.springframework.kafka.test.condition
-
JUnit5 condition for an embedded broker.
- EmbeddedKafkaCondition() - Constructor for class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
- EmbeddedKafkaRule - Class in org.springframework.kafka.test.rule
-
A
TestRule
wrapper around anEmbeddedKafkaBroker
. - EmbeddedKafkaRule(int) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
- EmbeddedKafkaRule(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Create embedded Kafka brokers listening on random ports.
- EmbeddedKafkaRule(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Create embedded Kafka brokers.
- EmbeddedZookeeper(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper
- EnableKafka - Annotation Type in org.springframework.kafka.annotation
-
Enable Kafka listener annotated endpoints that are created under the covers by a
AbstractListenerContainerFactory
. - EnableKafkaStreams - Annotation Type in org.springframework.kafka.annotation
-
Enable default Kafka Streams components.
- END - org.springframework.kafka.support.TopicPartitionOffset.SeekPosition
-
Seek to the end.
- endOffsets(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- enhancedObjectMapper() - Static method in class org.springframework.kafka.support.JacksonUtils
-
Factory for
ObjectMapper
instances with registered well-known modules and disabledMapperFeature.DEFAULT_VIEW_INCLUSION
andDeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES
features. - enhancedObjectMapper(ClassLoader) - Static method in class org.springframework.kafka.support.JacksonUtils
-
Factory for
ObjectMapper
instances with registered well-known modules and disabledMapperFeature.DEFAULT_VIEW_INCLUSION
andDeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES
features. - equals(Object) - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- equals(Object) - Method in class org.springframework.kafka.requestreply.CorrelationKey
- equals(Object) - Method in class org.springframework.kafka.support.TopicPartitionOffset
- equals(Object) - Method in class org.springframework.kafka.test.core.BrokerAddress
- ERROR - org.springframework.kafka.KafkaException.Level
-
Error.
- ERROR - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Error.
- errorHandler() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
Set an
KafkaListenerErrorHandler
bean name to invoke if the listener method throws an exception. - ErrorHandler - Interface in org.springframework.kafka.listener
-
Handles errors thrown during the execution of a
MessageListener
. - ErrorHandlingDeserializer<T> - Class in org.springframework.kafka.support.serializer
-
Delegating key/value deserializer that catches exceptions, returning them in the headers as serialized java objects.
- ErrorHandlingDeserializer() - Constructor for class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
- ErrorHandlingDeserializer(Deserializer<T>) - Constructor for class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
- evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
- evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition
- exchange(Message<?>) - Method in interface org.springframework.kafka.streams.messaging.MessagingFunction
- execute(KafkaOperations.ProducerCallback<Object, Object, T>) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Execute some arbitrary operation(s) on the producer and return the result.
- execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in class org.springframework.kafka.core.KafkaTemplate
- executeInTransaction(KafkaOperations.OperationsCallback<Object, Object, T>) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- executeInTransaction(KafkaOperations.OperationsCallback<K, V, T>) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Execute some arbitrary operation(s) on the operations and return the result.
- executeInTransaction(KafkaOperations.OperationsCallback<K, V, T>) - Method in class org.springframework.kafka.core.KafkaTemplate
- extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Subclasses can convert the value; by default, it's returned as provided by Kafka unless a
RecordMessageConverter
has been provided. - extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
- extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Subclasses can convert the value; by default, it's returned as provided by Kafka.
- extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.ProjectingMessageConverter
F
- FailedDeserializationInfo - Class in org.springframework.kafka.support.serializer
-
Class containing all the contextual information around a deserialization error.
- FailedDeserializationInfo(String, Headers, byte[], boolean, Exception) - Constructor for class org.springframework.kafka.support.serializer.FailedDeserializationInfo
-
Construct an instance with the contextual information.
- FailedRecordProcessor - Class in org.springframework.kafka.listener
-
Common super class for classes that deal with failing to consume a consumer record.
- FailedRecordProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - Constructor for class org.springframework.kafka.listener.FailedRecordProcessor
- failure(Object, String) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Record failure.
- FATAL - org.springframework.kafka.KafkaException.Level
-
Fatal.
- FATAL - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Fatal.
- filter(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener
- filter(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.adapter.RecordFilterStrategy
-
Return true if the record should be discarded.
- FilteringBatchMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
-
A
BatchMessageListener
adapter that implements filter logic via aRecordFilterStrategy
. - FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V>, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
-
Create an instance with the supplied strategy and delegate listener.
- FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - Constructor for class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
-
Create an instance with the supplied strategy and delegate listener.
- FilteringMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
-
A
MessageListener
adapter that implements filter logic via aRecordFilterStrategy
. - FilteringMessageListenerAdapter(MessageListener<K, V>, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
-
Create an instance with the supplied strategy and delegate listener.
- FilteringMessageListenerAdapter(MessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - Constructor for class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
-
Create an instance with the supplied strategy and delegate listener.
- findHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
- flush() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- flush() - Method in interface org.springframework.kafka.core.KafkaOperations
-
Flush the producer.
- flush() - Method in class org.springframework.kafka.core.KafkaTemplate
-
Flush the producer.
- flush() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- flush() - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- forKeys() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Designate this deserializer for deserializing keys (default is values); only applies if the default type mapper is used.
- forKeys() - Method in class org.springframework.kafka.support.serializer.JsonSerde
-
Designate this Serde for serializing/deserializing keys (default is values).
- forKeys() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Designate this serializer for serializing keys (default is values); only applies if the default type mapper is used.
- fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress
- fromClass(Class<?>, Headers) - Method in interface org.springframework.kafka.support.converter.ClassMapper
- fromClass(Class<?>, Headers) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- fromHeaders(MessageHeaders, Headers) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
- fromHeaders(MessageHeaders, Headers) - Method in interface org.springframework.kafka.support.KafkaHeaderMapper
-
Map from the given
MessageHeaders
to the specified target message. - fromHeaders(MessageHeaders, Headers) - Method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper
- fromJavaType(JavaType, Headers) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- fromJavaType(JavaType, Headers) - Method in interface org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
- fromMessage(Message<?>, String) - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter
-
Convert a message to a producer record.
- fromMessage(Message<?>, String) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
- fromMessage(Message<?>, String) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
- fromMessage(Message<?>, String) - Method in interface org.springframework.kafka.support.converter.RecordMessageConverter
-
Convert a message to a producer record.
G
- GenericErrorHandler<T> - Interface in org.springframework.kafka.listener
-
A generic error handler.
- GenericMessageListener<T> - Interface in org.springframework.kafka.listener
-
Top level interface for listeners.
- GenericMessageListenerContainer<K,V> - Interface in org.springframework.kafka.listener
-
Generic message listener container; adds parameters.
- get() - Method in class org.springframework.kafka.core.ABSwitchCluster
- getAckCount() - Method in class org.springframework.kafka.listener.ContainerProperties
- getAckMode() - Method in class org.springframework.kafka.listener.ContainerProperties
- getAckTime() - Method in class org.springframework.kafka.listener.ContainerProperties
- getAdviceChain() - Method in class org.springframework.kafka.listener.ContainerProperties
-
A chain of listener
Advice
s. - getAfterRollbackProcessor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Return the currently configured
AfterRollbackProcessor
. - getAllListenerContainers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
Return all
MessageListenerContainer
instances including those managed by this registry and those declared as beans in the application context. - getApplicationContext() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getApplicationEventPublisher() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getAssignedPartitions() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- getAssignedPartitions() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Return the
TopicPartition
s currently assigned to this container, either explicitly or by Kafka; may be null if not assigned yet. - getAssignedPartitions() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return the assigned topics/partitions for this container.
- getAssignedReplyTopicPartitions() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Return the topics/partitions assigned to the replying listener container.
- getAssignmentCommitOption() - Method in class org.springframework.kafka.listener.ContainerProperties
- getAssignmentsByClientId() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- getAssignmentsByClientId() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
- getAssignmentsByClientId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return the assigned topics/partitions for this container, by client.id.
- getAuthorizationExceptionRetryInterval() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getAutoStartup() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getAutoStartup() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the autoStartup for this endpoint's container.
- getBatchMessageConverter() - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Return the
BatchMessagingMessageConverter
for this listener, being able to convertMessage
. - getBatchToRecordAdapter() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getBean() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
- getBean() - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Return the bean for this handler.
- getBean() - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
- getBeanExpressionContext() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getBeanFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getBeanName() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getBeanResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getBootstrapServers() - Method in class org.springframework.kafka.core.KafkaResourceFactory
- getBroker() - Static method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
- getBrokerAddress(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getBrokerAddresses() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getBrokersAsString() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getCache() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getCache(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getCallbacksAndTopics() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
Return the currently registered callbacks and their associated
TopicPartition
(s). - getCharset() - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
- getCharset() - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Get the configured charset.
- getCharset() - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Get the configured charset.
- getClassIdFieldName() - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- getClassifier() - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Return the exception classifier.
- getClassLoader() - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- getClientId() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Return the client id.
- getClientIdPrefix() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getClientIdPrefix() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the client id prefix for the container; it will be suffixed by '-n' to provide a unique id when concurrency is used.
- getCommitCallback() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getCommitLogLevel() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
The level at which to log offset commits.
- getCommitRetries() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
The number of retries allowed when a
RetriableCommitFailedException
is thrown by the consumer. - getConcurrency() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getConcurrency() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the concurrency for this endpoint's container.
- getConcurrency() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- getConfig() - Method in class org.springframework.kafka.core.KafkaAdmin
-
Deprecated.in favor of
KafkaAdmin.getConfigurationProperties()
. - getConfigurationProperties() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Return an unmodifiable reference to the configuration map for this factory.
- getConfigurationProperties() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- getConfigurationProperties() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Return an unmodifiable reference to the configuration map for this factory.
- getConfigurationProperties() - Method in class org.springframework.kafka.core.KafkaAdmin
-
Get an unmodifiable copy of this admin's configuration.
- getConfigurationProperties() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return an unmodifiable reference to the configuration map for this factory.
- getConsumer() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent
- getConsumer() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
-
Retrieve the consumer.
- getConsumer() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
Retrieve the consumer.
- getConsumerFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- getConsumerGroupId() - Static method in class org.springframework.kafka.support.KafkaUtils
-
Get the group id for the consumer bound to this thread.
- getConsumerProperties() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getConsumerProperties() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Get the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
- getConsumerRebalanceListener() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getConsumerStartTimout() - Method in class org.springframework.kafka.listener.ContainerProperties
- getConsumerTaskExecutor() - Method in class org.springframework.kafka.listener.ContainerProperties
- getContainer(Class<T>) - Method in class org.springframework.kafka.event.KafkaEvent
-
Get the container for which the event was published, which will be the parent container if the source that emitted the event is a child container, or the source itself otherwise.
- getContainerProperties() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Obtain the properties template for this factory - set properties as needed and they will be copied to a final properties instance for the endpoint.
- getContainerProperties() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getContainerProperties() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return the container properties for this container.
- getContainers() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
Return the list of
KafkaMessageListenerContainer
s created by this container. - getContentClassIdFieldName() - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- getContext() - Method in class org.springframework.kafka.streams.HeaderEnricher.Container
- getCorrelationId() - Method in class org.springframework.kafka.requestreply.CorrelationKey
- getCurrentOffset(String, String, String, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Get the current offset and metadata for the provided group/topic/partition.
- getCustomMethodArgumentResolvers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Return the list of
HandlerMethodArgumentResolver
. - getData() - Method in exception org.springframework.kafka.support.serializer.DeserializationException
-
Get the data that failed deserialization (value or key).
- getData() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- getDefaultReplyTimeout() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Return the reply timeout used if no replyTimeout is provided in the
ReplyingKafkaTemplate.sendAndReceive(ProducerRecord, Duration)
call. - getDefaultReplyTopicExpression() - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils
-
Return the default expression when no SendTo value is present.
- getDefaultTopic() - Method in class org.springframework.kafka.core.KafkaTemplate
-
The default topic for send methods where a topic is not provided.
- getDelegate() - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- getDelegate() - Method in interface org.springframework.kafka.listener.DelegatingMessageListener
-
Return the delegate.
- getDelegates() - Method in class org.springframework.kafka.support.CompositeProducerListener
- getEmbeddedKafka() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Return an underlying delegator
EmbeddedKafkaBroker
instance. - getEndpointDescription() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return a description for this endpoint.
- getEndpointDescription() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
- getEndpointRegistry() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Return the
KafkaListenerEndpointRegistry
instance for this registrar, may benull
. - getEosMode() - Method in class org.springframework.kafka.listener.ContainerProperties
-
Get the exactly once semantics mode.
- getException() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- getExceptionFromHeader(ConsumerRecord<?, ?>, String, LogAccessor) - Static method in class org.springframework.kafka.listener.ListenerUtils
-
Extract a
DeserializationException
from the supplied header name, if present. - getFailedProducerRecord() - Method in exception org.springframework.kafka.core.KafkaProducerException
-
Return the failed producer record.
- getGenericErrorHandler() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Get the configured error handler.
- getGroup() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getGroup() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the group of this endpoint or null if not in a group.
- getGroupId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getGroupId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the groupId of this endpoint - if present, overrides the
group.id
property of the consumer factory. - getGroupId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getGroupId() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getGroupId() - Method in exception org.springframework.kafka.listener.ListenerExecutionFailedException
-
Return the consumer group.id property of the container that threw this exception.
- getGroupId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return the
group.id
property for this container whether specifically set on the container or via a consumer property on the consumer factory. - getGroupId() - Static method in interface org.springframework.kafka.support.converter.MessageConverter
-
Get the thread bound group id.
- getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Determine the
InvocableHandlerMethod
for the provided type. - getHeaders() - Method in exception org.springframework.kafka.support.serializer.DeserializationException
-
Get the headers.
- getHeaders() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- getHeaderValue() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- getHost() - Method in class org.springframework.kafka.test.core.BrokerAddress
- getId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the id of this endpoint.
- getIdClassMapping() - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- getIdleBetweenPolls() - Method in class org.springframework.kafka.listener.ContainerProperties
- getIdleEventInterval() - Method in class org.springframework.kafka.listener.ContainerProperties
- getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
-
How long the container has been idle.
- getIndex() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
-
Return the index in the batch of the failed record.
- getKafkaConsumerProperties() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Get the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
- getKafkaServer(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getKafkaServers() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getKafkaStreams() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Get a managed by this
StreamsBuilderFactoryBean
KafkaStreams
instance. - getKey() - Method in class org.springframework.kafka.streams.HeaderEnricher.Container
- getKeyClassIdFieldName() - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- getKeyDeserializer() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Return the configured key deserializer (if provided as an object instead of a class name in the properties).
- getKeyDeserializer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- getKeySerializerSupplier() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getKeySerializerSupplier() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return a supplier for a key serializer.
- getListenerContainer(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
Return the
MessageListenerContainer
with the specified id ornull
if no such container exists. - getListenerContainerIds() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
Return the ids of the managed
MessageListenerContainer
instance(s). - getListenerContainers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
Return the managed
MessageListenerContainer
instance(s). - getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
-
The id of the listener (if
@KafkaListener
) or the container bean name. - getListenerId() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
The id of the listener (if
@KafkaListener
) or the container bean name. - getListenerId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getListenerId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
The 'id' attribute of a
@KafkaListener
or the bean name for spring-managed containers. - getListeners() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Get the current list of listeners.
- getListeners() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Get the current list of listeners.
- getListeners() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Get the current list of listeners.
- getListeners() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Get the current list of listeners.
- getListeners() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Get the current list of listeners.
- getLogDir() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper
- getLogLevel() - Method in class org.springframework.kafka.listener.KafkaExceptionLogLevelAware
-
Set the level at which the exception thrown by this handler is logged.
- getMessage() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
- getMessageConverter() - Method in class org.springframework.kafka.core.KafkaTemplate
-
Return the message converter.
- getMessageConverter() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Return the
MessagingMessageConverter
for this listener, being able to convertMessage
. - getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Return the custom
MessageHandlerMethodFactory
to use, if any. - getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Return the
MessageHandlerMethodFactory
. - getMessageListener() - Method in class org.springframework.kafka.listener.ContainerProperties
- getMethod() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
- getMethodAsString(Object) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
- getMethodNameFor(Object) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Return a string representation of the method that will be invoked for this payload.
- getMicrometerTags() - Method in class org.springframework.kafka.listener.ContainerProperties
- getMonitorInterval() - Method in class org.springframework.kafka.listener.ContainerProperties
- getNoPollThreshold() - Method in class org.springframework.kafka.listener.ContainerProperties
- getObjectMapper() - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
-
Return the object mapper.
- getObjectMapper() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Return the object mapper.
- getObjectType() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- getOffset() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- getOneRecord(String, String, String, int, boolean, boolean, long) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Get a single record for the group from the topic/partition.
- getOrder() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- getParser() - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Get the configured parser function.
- getPartition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- getPartitions() - Method in class org.springframework.kafka.event.ConsumerPausedEvent
- getPartitions() - Method in class org.springframework.kafka.event.ConsumerResumedEvent
- getPartitions() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent
- getPartitionsPerTopic() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getPhase() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- getPhase() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- getPhase() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getPhase() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- getPhysicalCloseTimeout() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Get the physical close timeout.
- getPhysicalCloseTimeout() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Get the physical close timeout.
- getPollTimeout() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getPort() - Method in class org.springframework.kafka.test.core.BrokerAddress
- getPort() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper
- getPosition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- getPostProcessors() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Get the current list of post processors.
- getPostProcessors() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- getPostProcessors() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getPostProcessors() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Get the current list of post processors.
- getProducer() - Method in class org.springframework.kafka.core.KafkaResourceHolder
- getProducerFactory() - Method in interface org.springframework.kafka.core.KafkaOperations
-
Return the producer factory used by this template.
- getProducerFactory() - Method in class org.springframework.kafka.core.KafkaTemplate
-
Return the producer factory used by this template.
- getProducerFactory() - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- getProducerFactory() - Method in class org.springframework.kafka.transaction.ChainedKafkaTransactionManager
- getProducerFactory() - Method in interface org.springframework.kafka.transaction.KafkaAwareTransactionManager
-
Get the producer factory.
- getProducerFactory() - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
-
Get the producer factory.
- getProducerFactory(String) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Return the producer factory used by this template based on the topic.
- getProducerFactory(String) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- getProducerRecord() - Method in exception org.springframework.kafka.core.KafkaProducerException
-
Deprecated.in favor of
KafkaProducerException.getFailedProducerRecord()
- getProducerRecord() - Method in class org.springframework.kafka.support.SendResult
- getPropertyValue(Object, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Uses nested
DirectFieldAccessor
s to obtain a property using dotted notation to traverse fields; e.g. - getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
A typed version of
getPropertyValue(Object, String)
. - getRawHeaders() - Method in class org.springframework.kafka.support.converter.KafkaMessageHeaders
- getRecord() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
-
Return the failed record.
- getRecordFilterStrategy() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getRecordInterceptor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- getRecordMessageConverter() - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter
-
Return the record converter used by this batch converter, if configured, or null.
- getRecordMessageConverter() - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
- getRecordMetadata() - Method in class org.springframework.kafka.support.SendResult
- getRecords(Consumer<K, V>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Poll the consumer for records.
- getRecords(Consumer<K, V>, long) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Poll the consumer for records.
- getRecords(Consumer<K, V>, long, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Poll the consumer for records.
- getRecoveryCallback() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getRecoveryCallback() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
- getReplyHeadersConfigurer() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Return the reply configurer.
- getReplyTemplate() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getRequest() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
- getResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getResult() - Method in class org.springframework.kafka.listener.adapter.InvocationResult
- getResult() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
- getRetryTemplate() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- getRetryTemplate() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
- getScheduler() - Method in class org.springframework.kafka.listener.ContainerProperties
- getSeekCallbackFor(TopicPartition) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
Return the callback for the specified topic/partition.
- getSeekCallbacks() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
The map of callbacks for all currently assigned partitions.
- getSendFuture() - Method in class org.springframework.kafka.requestreply.RequestReplyFuture
- getSendTo() - Method in class org.springframework.kafka.listener.adapter.InvocationResult
- getShutdownTimeout() - Method in class org.springframework.kafka.listener.ContainerProperties
- getSingleRecord(Consumer<K, V>, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Poll the consumer, expecting a single record for the specified topic.
- getSingleRecord(Consumer<K, V>, String, long) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Poll the consumer, expecting a single record for the specified topic.
- getSkipPredicate(List<ConsumerRecord<?, ?>>, Exception) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
- getSnapshotDir() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper
- getSource() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
- getSource(Class<T>) - Method in class org.springframework.kafka.event.KafkaEvent
-
Get the container (source) that published the event.
- getStreamsConfiguration() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- getSubBatchPerPartition() - Method in class org.springframework.kafka.listener.ContainerProperties
-
Return whether to split batches by partition; null if not set.
- getSyncCommitTimeout() - Method in class org.springframework.kafka.listener.ConsumerProperties
- getTheProducer(String) - Method in class org.springframework.kafka.core.KafkaTemplate
- getTimeSinceLastPoll() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
How long since the last poll.
- getTopic() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- getTopic() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- getTopicPartition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- getTopicPartitions() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
-
The TopicPartitions the container is listening to.
- getTopicPartitions() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
The TopicPartitions the container is listening to.
- getTopicPartitions() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Return the configured
TopicPartitionOffset
s. - getTopicPartitionsToAssign() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topicPartitions for this endpoint.
- getTopicPartitionsToAssign() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topicPartitions for this endpoint.
- getTopicPartitionsToAssign() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Deprecated.in favor of
ConsumerProperties.getTopicPartitions()
. - getTopicPattern() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topicPattern for this endpoint.
- getTopicPattern() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topicPattern for this endpoint.
- getTopicPattern() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Return the configured topic pattern.
- getTopics() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topics for this endpoint.
- getTopics() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topics for this endpoint.
- getTopics() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Return the configured topics.
- getTopics() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getTopology() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Providing access to the associated
Topology
of thisStreamsBuilderFactoryBean
. - getToStringClasses() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Provide direct access to the toString() classes by subclasses.
- getTransactionalResourceHolder(ProducerFactory<K, V>) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
-
Obtain a Producer that is synchronized with the current transaction, if any.
- getTransactionalResourceHolder(ProducerFactory<K, V>, String, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
-
Obtain a Producer that is synchronized with the current transaction, if any.
- getTransactionalResourceHolder(ProducerFactory<K, V>, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
-
Obtain a Producer that is synchronized with the current transaction, if any.
- getTransactionDefinition() - Method in class org.springframework.kafka.listener.ContainerProperties
-
Get the transaction definition.
- getTransactionIdPrefix() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getTransactionIdPrefix() - Method in class org.springframework.kafka.core.KafkaTemplate
- getTransactionIdPrefix() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return the transaction id prefix.
- getTransactionIdSuffix() - Static method in class org.springframework.kafka.support.TransactionSupport
- getTransactionManager() - Method in class org.springframework.kafka.listener.ContainerProperties
- getTrustedPackages() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Provide direct access to the trusted packages set for subclasses.
- getType() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Returns the inferred type for conversion or, if null, the
fallbackType
. - getTypeMapper() - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
- getTypeMapper() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
- getTypeMapper() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
- getTypePrecedence() - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
-
Return the precedence.
- getTypePrecedence() - Method in interface org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
- getUntrustedType() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- getValidator() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Get the validator, if supplied.
- getValue() - Method in class org.springframework.kafka.streams.HeaderEnricher.Container
- getValueDeserializer() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Return the configured value deserializer (if provided as an object instead of a class name in the properties).
- getValueDeserializer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- getValueSerializerSupplier() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- getValueSerializerSupplier() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return a supplier for a value serializer.
- getZkPort() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Get the port that the embedded Zookeeper is running on or will run on.
- getZookeeper() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- getZooKeeperClient() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Return the ZooKeeperClient.
- getZookeeperConnectionString() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
- GROUP_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
For inbound messages, the container's
group.id
consumer property. - groupId() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
Override the
group.id
property for the consumer factory with this value for this listener only.
H
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ContainerAwareErrorHandler
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
-
Handle the exception.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ContainerAwareErrorHandler
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.ContainerStoppingErrorHandler
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ErrorHandler
-
Handle the exception.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.SeekToCurrentErrorHandler
- handle(Exception, ConsumerRecord<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
- handle(Exception, ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.listener.LoggingErrorHandler
- handle(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
- handle(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
- handle(Exception, ConsumerRecords<?, ?>) - Method in class org.springframework.kafka.listener.BatchLoggingErrorHandler
- handle(Exception, ConsumerRecords<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.BatchErrorHandler
-
Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.ContainerStoppingBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.RecoveringBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.BatchErrorHandler
-
Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
-
Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.RetryingBatchErrorHandler
- handle(Exception, T) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Handle the exception.
- handle(Exception, T, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Handle the exception.
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - Method in class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
- handleError(Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.kafka.listener.ConsumerAwareListenerErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.kafka.listener.KafkaListenerErrorHandler
-
Handle the error.
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareListenerErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.KafkaListenerErrorHandler
-
Handle the error.
- HandlerAdapter - Class in org.springframework.kafka.listener.adapter
-
A wrapper for either an
InvocableHandlerMethod
orDelegatingInvocableHandler
. - HandlerAdapter(DelegatingInvocableHandler) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter
- HandlerAdapter(InvocableHandlerMethod) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter
- handleResult(Object, Object, Object) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Handle the given result object returned from the listener method, sending a response message to the SendTo topic.
- handleTimeout(CorrelationKey, RequestReplyFuture<K, V, Collection<ConsumerRecord<K, R>>>) - Method in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
- handleTimeout(CorrelationKey, RequestReplyFuture<K, V, R>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Used to inform subclasses that a request has timed out so they can clean up state and, optionally, complete the future.
- hasDefaultHandler() - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
- hashCode() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hashCode() - Method in class org.springframework.kafka.requestreply.CorrelationKey
- hashCode() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- hashCode() - Method in class org.springframework.kafka.test.core.BrokerAddress
- hasKey(K) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- hasOffset() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hasPartition(int) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- hasTimestamp() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hasTimestamp(long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
-
Matcher testing the timestamp of a
ConsumerRecord
assuming the topic has been set withCreateTime
. - hasTimestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
-
Matcher testing the timestamp of a
ConsumerRecord
- hasValue(V) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- HeaderEnricher<K,V> - Class in org.springframework.kafka.streams
-
Manipulate the headers.
- HeaderEnricher(Map<String, Expression>) - Constructor for class org.springframework.kafka.streams.HeaderEnricher
- HeaderEnricher.Container<K,V> - Class in org.springframework.kafka.streams
-
Container object for SpEL evaluation.
- headerValueToAddIn(Header) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Check if the header value should be mapped to a String, if so configured.
- headerValueToAddOut(String, Object) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Check if the value is a String and convert to byte[], if so configured.
I
- id() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
The unique identifier of the container managing for this endpoint.
- idIsGroup() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
- ignoreTypeHeaders() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Ignore type information headers and use the configured target class.
- ignoreTypeHeaders() - Method in class org.springframework.kafka.support.serializer.JsonSerde
-
Ignore type information headers and use the configured target class.
- INFERRED - org.springframework.kafka.support.converter.Jackson2JavaTypeMapper.TypePrecedence
- INFO - org.springframework.kafka.KafkaException.Level
-
Info.
- INFO - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Info.
- init(ProcessorContext) - Method in class org.springframework.kafka.streams.HeaderEnricher
- init(ProcessorContext) - Method in class org.springframework.kafka.streams.messaging.MessagingTransformer
- initialize() - Method in class org.springframework.kafka.core.KafkaAdmin
-
Call this method to check/add topics; this might be needed if the broker was not available when the application context was initialized, and
fatalIfBrokerNotAvailable
is false, orautoCreate
was set to false. - initializeContainer(C, KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Further initialize the specified container.
- initializeContainer(ConcurrentMessageListenerContainer<K, V>, KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
- initialOffset() - Method in annotation type org.springframework.kafka.annotation.PartitionOffset
-
The initial offset of the
PartitionOffset.partition()
. - initialRecordHeaders(Message<?>) - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
- initialRecordHeaders(Message<?>) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Subclasses can populate additional headers before they are mapped.
- initTransactions() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- INSTANCE - Static variable in class org.springframework.kafka.support.JavaUtils
-
The singleton instance of this utility class.
- INSTANCE - Static variable in class org.springframework.kafka.support.KafkaNull
-
Instance of KafkaNull.
- instantiateAndConfigure(Map<String, ?>, boolean, Map<String, Deserializer<?>>, String, Class<?>) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
- instantiateAndConfigure(Map<String, ?>, boolean, Map<String, Serializer<?>>, String, Class<?>) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer
- intercept(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.CompositeRecordInterceptor
- intercept(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.RecordInterceptor
-
Perform some action on the record or return a different one.
- inTransaction() - Method in interface org.springframework.kafka.core.KafkaOperations
-
Return true if the template is currently running in a transaction on the calling thread.
- inTransaction() - Method in class org.springframework.kafka.core.KafkaTemplate
-
Return true if the template is currently running in a transaction on the calling thread.
- InvocationResult - Class in org.springframework.kafka.listener.adapter
-
The result of a method invocation.
- InvocationResult(Object, Expression, boolean) - Constructor for class org.springframework.kafka.listener.adapter.InvocationResult
- invoke(Object, Acknowledgment, Consumer<?, ?>, Message<?>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
- invoke(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>, Message<?>) - Method in interface org.springframework.kafka.listener.adapter.BatchToRecordAdapter.Callback
-
Handle each message.
- invoke(Message<?>, Object...) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Invoke the method with the given message.
- invoke(Message<?>, Object...) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
- invokeHandler(Object, Acknowledgment, Message<?>, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Invoke the handler, wrapping any exception to a
ListenerExecutionFailedException
with a dedicated error message. - isAckAfterHandle() - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Return true if the offset should be committed for a handled error (no exception thrown).
- isAckAfterHandle() - Method in class org.springframework.kafka.listener.RecoveringBatchErrorHandler
- isAckAfterHandle() - Method in class org.springframework.kafka.listener.RetryingBatchErrorHandler
- isAckAfterHandle() - Method in class org.springframework.kafka.listener.SeekToCurrentErrorHandler
- isAckDiscarded() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- isAckOnError() - Method in class org.springframework.kafka.listener.ContainerProperties
- isAddTypeInfo() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
- isAddTypeInfo() - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Get the addTypeInfo property.
- isAllowNonTransactional() - Method in interface org.springframework.kafka.core.KafkaOperations
-
Return true if this template, when transactional, allows non-transactional operations.
- isAllowNonTransactional() - Method in class org.springframework.kafka.core.KafkaTemplate
- isAutoCommit() - Method in interface org.springframework.kafka.core.ConsumerFactory
-
Return true if consumers created by this factory use auto commit.
- isAutoCommit() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- isAutoStartup() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- isAutoStartup() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- isAutoStartup() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- isAutoStartup() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- isBatchListener() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Return true if this endpoint creates a batch listener.
- isBatchListener() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return true if this endpoint creates a batch listener.
- isCommitRecovered() - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Whether the offset for a recovered record should be committed.
- isConsumerRecordList() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- isConsumerRecords() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- isContainerPaused() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- isContainerPaused() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
- isContainerPaused() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return true if
MessageListenerContainer.pause()
has been called; and all consumers in this container have actually paused. - isConversionNeeded() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- isDefault() - Method in annotation type org.springframework.kafka.annotation.KafkaHandler
-
When true, designate that this is the default fallback method if the payload type matches no other
KafkaHandler
method. - isDeliveryAttemptHeader() - Method in class org.springframework.kafka.listener.ContainerProperties
- isEncodeStrings() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
- isExistingTransaction(Object) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
- isFixTxOffsets() - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Whether or not to correct terminal transactional offsets.
- isForKey() - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
- isForKey() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- isInterceptBeforeTx() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- isJackson2Present() - Static method in class org.springframework.kafka.support.JacksonPresent
- isKey() - Method in exception org.springframework.kafka.support.serializer.DeserializationException
-
True if deserialization of the key failed, otherwise deserialization of the value failed.
- isLogContainerConfig() - Method in class org.springframework.kafka.listener.ContainerProperties
-
Log the container configuration if true (INFO).
- isMessageList() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- isMessageReturnType() - Method in class org.springframework.kafka.listener.adapter.InvocationResult
- isMicrometerEnabled() - Method in class org.springframework.kafka.listener.ContainerProperties
- isMissingTopicsFatal() - Method in class org.springframework.kafka.listener.ContainerProperties
-
If true, the container won't start if any of the configured topics are not present on the broker.
- isNegated() - Method in interface org.springframework.kafka.support.AbstractKafkaHeaderMapper.HeaderMatcher
-
Return true if this matcher is a negative matcher.
- isNegated() - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher
- isNegated() - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
- isOnlyLogRecordMetadata() - Method in class org.springframework.kafka.listener.ConsumerProperties
- isPaused() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
-
Return true if the consumer was paused at the time the idle event was published.
- isPaused() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- isPauseRequested() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- isPauseRequested() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return true if
MessageListenerContainer.pause()
has been called; the container might not have actually paused yet. - isPending(CorrelationKey) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Return true if this correlation id is still active.
- isPrimary() - Method in class org.springframework.kafka.core.ABSwitchCluster
-
Get whether or not the primary cluster is active.
- isProcessInTransaction() - Method in interface org.springframework.kafka.listener.AfterRollbackProcessor
-
Return true to invoke
AfterRollbackProcessor.process(List, Consumer, Exception, boolean, ContainerProperties.EOSMode)
in a new transaction. - isProcessInTransaction() - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
- isProducerPerConsumerPartition() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Return the producerPerConsumerPartition.
- isProducerPerConsumerPartition() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return the producerPerConsumerPartition.
- isProducerPerThread() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- isProducerPerThread() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return true when there is a producer per thread.
- isRelativeToCurrent() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- isRunning() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- isRunning() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- isRunning() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- isRunning() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- isSplitIterables() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- isSplitIterables() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
When true,
Iterable
return results will be split into discrete records. - isSplitIterables() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
When true,
Iterable
return results will be split into discrete records. - isStatefulRetry() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- isSubBatchPerPartition() - Method in class org.springframework.kafka.listener.ContainerProperties
-
Return whether to split batches by partition.
- isSyncCommits() - Method in class org.springframework.kafka.listener.ConsumerProperties
- isTransactional() - Method in interface org.springframework.kafka.core.KafkaOperations
-
Return true if the implementation supports transactions (has a transaction-capable producer factory).
- isTransactional() - Method in class org.springframework.kafka.core.KafkaTemplate
J
- Jackson2JavaTypeMapper - Interface in org.springframework.kafka.support.converter
-
Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
- Jackson2JavaTypeMapper.TypePrecedence - Enum in org.springframework.kafka.support.converter
-
The precedence for type conversion - inferred from the method parameter or message headers.
- JacksonMimeTypeModule - Class in org.springframework.kafka.support
-
A
SimpleModule
extension forMimeType
serialization. - JacksonMimeTypeModule() - Constructor for class org.springframework.kafka.support.JacksonMimeTypeModule
- JacksonPresent - Class in org.springframework.kafka.support
-
The utility to check if Jackson JSON processor is present in the classpath.
- JacksonUtils - Class in org.springframework.kafka.support
-
The utilities for Jackson
ObjectMapper
instances. - JavaUtils - Class in org.springframework.kafka.support
-
Chained utility methods to simplify some Java repetitive code.
- JSON_TYPES - Static variable in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Header name for java types of other headers.
- JsonDeserializer<T> - Class in org.springframework.kafka.support.serializer
-
Generic
Deserializer
for receiving JSON from Kafka and return Java objects. - JsonDeserializer() - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with a default
ObjectMapper
. - JsonDeserializer(TypeReference<? super T>) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and a default
ObjectMapper
. - JsonDeserializer(TypeReference<? super T>, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and useHeadersIfPresent with a default
ObjectMapper
. - JsonDeserializer(TypeReference<? super T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and
ObjectMapper
. - JsonDeserializer(TypeReference<? super T>, ObjectMapper, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type,
ObjectMapper
and useHeadersIfPresent. - JsonDeserializer(JavaType) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and a default
ObjectMapper
. - JsonDeserializer(JavaType, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and useHeadersIfPresent with a default
ObjectMapper
. - JsonDeserializer(JavaType, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and
ObjectMapper
. - JsonDeserializer(JavaType, ObjectMapper, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type,
ObjectMapper
and useHeadersIfPresent. - JsonDeserializer(ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided
ObjectMapper
. - JsonDeserializer(Class<? super T>) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and a default
ObjectMapper
. - JsonDeserializer(Class<? super T>, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and useHeadersIfPresent with a default
ObjectMapper
. - JsonDeserializer(Class<? super T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type, and
ObjectMapper
. - JsonDeserializer(Class<? super T>, ObjectMapper, boolean) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
-
Construct an instance with the provided target type,
ObjectMapper
and useHeadersIfPresent. - JsonMessageConverter - Class in org.springframework.kafka.support.converter
-
Base class for JSON message converters; on the consumer side, it can handle
byte[]
,Bytes
andString
record values. - JsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.JsonMessageConverter
- JsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.JsonMessageConverter
- JsonSerde<T> - Class in org.springframework.kafka.support.serializer
-
A
Serde
that provides serialization and deserialization in JSON format. - JsonSerde() - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(TypeReference<? super T>) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(TypeReference<? super T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(JavaType) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(JavaType, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(Class<? super T>) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(Class<? super T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerde(JsonSerializer<T>, JsonDeserializer<T>) - Constructor for class org.springframework.kafka.support.serializer.JsonSerde
- JsonSerializer<T> - Class in org.springframework.kafka.support.serializer
-
Generic
Serializer
for sending Java objects to Kafka as JSON. - JsonSerializer() - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
- JsonSerializer(TypeReference<? super T>) - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
- JsonSerializer(TypeReference<? super T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
- JsonSerializer(JavaType, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
- JsonSerializer(ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
- JsonTypeResolver - Interface in org.springframework.kafka.support.serializer
-
Determine the
JavaType
from the topic/data/headers. - JUnitUtils - Class in org.springframework.kafka.test.utils
-
Utility methods for JUnit rules and conditions.
- JUnitUtils.LevelsContainer - Class in org.springframework.kafka.test.utils
K
- KAFKA_CLIENT_CONTEXT_NAME - Static variable in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
-
The key for the kafka client configuration entry.
- KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils
-
The bean name of the internally managed Kafka listener annotation processor.
- KAFKA_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils
-
The bean name of the internally managed Kafka listener endpoint registry.
- KafkaAdmin - Class in org.springframework.kafka.core
-
An admin that delegates to an
AdminClient
to create topics defined in the application context. - KafkaAdmin(Map<String, Object>) - Constructor for class org.springframework.kafka.core.KafkaAdmin
-
Create an instance with an
AdminClient
based on the supplied configuration. - KafkaAwareTransactionManager<K,V> - Interface in org.springframework.kafka.transaction
-
A transaction manager that can provide a
ProducerFactory
. - KafkaBootstrapConfiguration - Class in org.springframework.kafka.annotation
-
An
ImportBeanDefinitionRegistrar
class that registers aKafkaListenerAnnotationBeanPostProcessor
bean capable of processing Spring's @KafkaListener
annotation. - KafkaBootstrapConfiguration() - Constructor for class org.springframework.kafka.annotation.KafkaBootstrapConfiguration
- KafkaConditions - Class in org.springframework.kafka.test.assertj
-
AssertJ custom
Condition
s. - KafkaConditions.ConsumerRecordKeyCondition<K> - Class in org.springframework.kafka.test.assertj
- KafkaConditions.ConsumerRecordKeyValueCondition<K,V> - Class in org.springframework.kafka.test.assertj
- KafkaConditions.ConsumerRecordPartitionCondition - Class in org.springframework.kafka.test.assertj
- KafkaConditions.ConsumerRecordTimestampCondition - Class in org.springframework.kafka.test.assertj
- KafkaConditions.ConsumerRecordValueCondition<V> - Class in org.springframework.kafka.test.assertj
- KafkaEvent - Class in org.springframework.kafka.event
-
Base class for events.
- KafkaEvent(Object) - Constructor for class org.springframework.kafka.event.KafkaEvent
-
Deprecated.
- KafkaEvent(Object, Object) - Constructor for class org.springframework.kafka.event.KafkaEvent
- KafkaException - Exception in org.springframework.kafka
-
The Spring Kafka specific
NestedRuntimeException
implementation. - KafkaException(String) - Constructor for exception org.springframework.kafka.KafkaException
-
Construct an instance with the provided properties.
- KafkaException(String, Throwable) - Constructor for exception org.springframework.kafka.KafkaException
-
Construct an instance with the provided properties.
- KafkaException(String, KafkaException.Level, Throwable) - Constructor for exception org.springframework.kafka.KafkaException
-
Construct an instance with the provided properties.
- KafkaException.Level - Enum in org.springframework.kafka
-
The log level for
KafkaException
. - KafkaExceptionLogLevelAware - Class in org.springframework.kafka.listener
-
A top level abstract class for classes that can be configured with a
KafkaException.Level
. - KafkaExceptionLogLevelAware() - Constructor for class org.springframework.kafka.listener.KafkaExceptionLogLevelAware
- KafkaFailureCallback<K,V> - Interface in org.springframework.kafka.core
-
An enhanced
FailureCallback
for reportingKafkaProducerException
s. - KafkaHandler - Annotation Type in org.springframework.kafka.annotation
-
Annotation that marks a method to be the target of a Kafka message listener within a class that is annotated with
KafkaListener
. - KafkaHeaderMapper - Interface in org.springframework.kafka.support
-
Header mapper for Apache Kafka.
- KafkaHeaders - Class in org.springframework.kafka.support
-
The Kafka specific message headers constants.
- KafkaHeaders() - Constructor for class org.springframework.kafka.support.KafkaHeaders
- KafkaJaasLoginModuleInitializer - Class in org.springframework.kafka.security.jaas
-
Contains properties for setting up an
AppConfigurationEntry
that can be used for the Kafka client. - KafkaJaasLoginModuleInitializer() - Constructor for class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
- KafkaJaasLoginModuleInitializer.ControlFlag - Enum in org.springframework.kafka.security.jaas
-
Control flag values for login configuration.
- KafkaListener - Annotation Type in org.springframework.kafka.annotation
-
Annotation that marks a method to be the target of a Kafka message listener on the specified topics.
- KafkaListenerAnnotationBeanPostProcessor<K,V> - Class in org.springframework.kafka.annotation
-
Bean post-processor that registers methods annotated with
KafkaListener
to be invoked by a Kafka message listener container created under the covers by aKafkaListenerContainerFactory
according to the parameters of the annotation. - KafkaListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- KafkaListenerConfigurationSelector - Class in org.springframework.kafka.annotation
-
A
DeferredImportSelector
implementation with the lowest order to import aKafkaBootstrapConfiguration
as late as possible. - KafkaListenerConfigurationSelector() - Constructor for class org.springframework.kafka.annotation.KafkaListenerConfigurationSelector
- KafkaListenerConfigurer - Interface in org.springframework.kafka.annotation
-
Optional interface to be implemented by Spring managed bean willing to customize how Kafka listener endpoints are configured.
- KafkaListenerConfigUtils - Class in org.springframework.kafka.config
-
Configuration constants for internal sharing across subpackages.
- KafkaListenerConfigUtils() - Constructor for class org.springframework.kafka.config.KafkaListenerConfigUtils
- KafkaListenerContainerFactory<C extends MessageListenerContainer> - Interface in org.springframework.kafka.config
-
Factory for
MessageListenerContainer
s. - KafkaListenerEndpoint - Interface in org.springframework.kafka.config
-
Model for a Kafka listener endpoint.
- KafkaListenerEndpointRegistrar - Class in org.springframework.kafka.config
-
Helper bean for registering
KafkaListenerEndpoint
with aKafkaListenerEndpointRegistry
. - KafkaListenerEndpointRegistrar() - Constructor for class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
- KafkaListenerEndpointRegistry - Class in org.springframework.kafka.config
-
Creates the necessary
MessageListenerContainer
instances for the registered endpoints. - KafkaListenerEndpointRegistry() - Constructor for class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- KafkaListenerErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler which is called when a
@KafkaListener
method throws an exception. - KafkaListeners - Annotation Type in org.springframework.kafka.annotation
-
Container annotation that aggregates several
KafkaListener
annotations. - KafkaMatchers - Class in org.springframework.kafka.test.hamcrest
-
Hamcrest
Matcher
s utilities. - KafkaMatchers.ConsumerRecordKeyMatcher<K> - Class in org.springframework.kafka.test.hamcrest
- KafkaMatchers.ConsumerRecordPartitionMatcher - Class in org.springframework.kafka.test.hamcrest
- KafkaMatchers.ConsumerRecordTimestampMatcher - Class in org.springframework.kafka.test.hamcrest
- KafkaMatchers.ConsumerRecordValueMatcher<V> - Class in org.springframework.kafka.test.hamcrest
- KafkaMessageHeaders - Class in org.springframework.kafka.support.converter
-
Overload of message headers configurable for adding id and timestamp headers.
- KafkaMessageListenerContainer<K,V> - Class in org.springframework.kafka.listener
-
Single-threaded Message listener container using the Java
Consumer
supporting auto-partition assignment or user-configured assignment. - KafkaMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Construct an instance with the supplied configuration properties.
- KafkaNull - Class in org.springframework.kafka.support
-
This class represents NULL Kafka payload.
- KafkaOperations<K,V> - Interface in org.springframework.kafka.core
-
The basic Kafka operations contract returning
ListenableFuture
s. - KafkaOperations.OperationsCallback<K,V,T> - Interface in org.springframework.kafka.core
-
A callback for executing arbitrary operations on the
KafkaOperations
. - KafkaOperations.ProducerCallback<K,V,T> - Interface in org.springframework.kafka.core
-
A callback for executing arbitrary operations on the
Producer
. - kafkaPorts(int...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set explicit ports on which the kafka brokers will listen.
- kafkaPorts(int...) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
-
Set explicit ports on which the kafka brokers will listen.
- KafkaProducerException - Exception in org.springframework.kafka.core
-
Exceptions when producing.
- KafkaProducerException(ProducerRecord<?, ?>, String, Throwable) - Constructor for exception org.springframework.kafka.core.KafkaProducerException
-
Construct an instance with the provided properties.
- KafkaReplyTimeoutException - Exception in org.springframework.kafka.requestreply
-
Exception when a reply is not received within a timeout.
- KafkaReplyTimeoutException(String) - Constructor for exception org.springframework.kafka.requestreply.KafkaReplyTimeoutException
- KafkaResourceFactory - Class in org.springframework.kafka.core
-
Base class for consumer/producer/admin creators.
- KafkaResourceFactory() - Constructor for class org.springframework.kafka.core.KafkaResourceFactory
- KafkaResourceHolder<K,V> - Class in org.springframework.kafka.core
-
Kafka resource holder, wrapping a Kafka producer.
- KafkaResourceHolder(Producer<K, V>, Duration) - Constructor for class org.springframework.kafka.core.KafkaResourceHolder
-
Construct an instance for the producer.
- KafkaSendCallback<K,V> - Interface in org.springframework.kafka.core
-
An enhanced
ListenableFutureCallback
for reportingKafkaProducerException
s. - KafkaStreamBrancher<K,V> - Class in org.springframework.kafka.support
-
Provides a method-chaining way to build
branches
in Kafka Streams processor topology. - KafkaStreamBrancher() - Constructor for class org.springframework.kafka.support.KafkaStreamBrancher
- KafkaStreamsConfiguration - Class in org.springframework.kafka.config
-
Wrapper for
StreamsBuilder
properties. - KafkaStreamsConfiguration(Map<String, Object>) - Constructor for class org.springframework.kafka.config.KafkaStreamsConfiguration
- KafkaStreamsCustomizer - Interface in org.springframework.kafka.config
-
Callback interface that can be used to configure
KafkaStreams
directly. - KafkaStreamsDefaultConfiguration - Class in org.springframework.kafka.annotation
-
@Configuration
class that registers aStreamsBuilderFactoryBean
ifStreamsConfig
with the nameKafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME
is present in the application context. - KafkaStreamsDefaultConfiguration() - Constructor for class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration
- KafkaStreamsInfrastructureCustomizer - Interface in org.springframework.kafka.config
-
A customizer for infrastructure components such as the
StreamsBuilder
andTopology
. - KafkaStreamsMicrometerListener - Class in org.springframework.kafka.streams
-
Creates a
KafkaStreamsMetrics
for theKafkaStreams
. - KafkaStreamsMicrometerListener(MeterRegistry) - Constructor for class org.springframework.kafka.streams.KafkaStreamsMicrometerListener
-
Construct an instance with the provided registry.
- KafkaStreamsMicrometerListener(MeterRegistry, List<Tag>) - Constructor for class org.springframework.kafka.streams.KafkaStreamsMicrometerListener
-
Construct an instance with the provided registry and tags.
- KafkaTemplate<K,V> - Class in org.springframework.kafka.core
-
A template for executing high-level operations.
- KafkaTemplate(ProducerFactory<K, V>) - Constructor for class org.springframework.kafka.core.KafkaTemplate
-
Create an instance using the supplied producer factory and autoFlush false.
- KafkaTemplate(ProducerFactory<K, V>, boolean) - Constructor for class org.springframework.kafka.core.KafkaTemplate
-
Create an instance using the supplied producer factory and autoFlush setting.
- KafkaTemplate(ProducerFactory<K, V>, boolean, Map<String, Object>) - Constructor for class org.springframework.kafka.core.KafkaTemplate
-
Create an instance using the supplied producer factory and autoFlush setting.
- KafkaTemplate(ProducerFactory<K, V>, Map<String, Object>) - Constructor for class org.springframework.kafka.core.KafkaTemplate
-
Create an instance using the supplied producer factory and properties, with autoFlush false.
- KafkaTestUtils - Class in org.springframework.kafka.test.utils
-
Kafka testing utilities.
- KafkaTransactionManager<K,V> - Class in org.springframework.kafka.transaction
-
PlatformTransactionManager
implementation for a single KafkaProducerFactory
. - KafkaTransactionManager(ProducerFactory<K, V>) - Constructor for class org.springframework.kafka.transaction.KafkaTransactionManager
-
Create a new KafkaTransactionManager, given a ProducerFactory.
- KafkaUtils - Class in org.springframework.kafka.support
-
Utility methods.
- key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- KEY_DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Default header name for key type information.
- KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Default header name for key container object contents type information.
- KEY_DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Default header name for key map key type information.
- KEY_DEFAULT_TYPE - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property for the default key type if no header.
- KEY_DESERIALIZER_CLASS - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Property name for the delegate key deserializer.
- KEY_DESERIALIZER_EXCEPTION_HEADER - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Header name for deserialization exceptions.
- KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Header name for deserialization exceptions.
- KEY_FUNCTION - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Supplier for a T when deserialization fails.
- KEY_PARSER - Static variable in class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Property for the key parser method.
- KEY_SERIALIZATION_SELECTOR - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Name of the header containing the serialization selector for keys.
- KEY_SERIALIZATION_SELECTOR_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Name of the configuration property containing the serialization selector map for keys with format
selector:class,...
. - KEY_TYPE - Static variable in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Header for the type of key.
- KEY_TYPE_METHOD - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
A method name to determine the
JavaType
to deserialize the key to. - keyDeserializer(boolean) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Set to true if this deserializer is to be used as a key deserializer when configuring outside of Kafka.
- keyValue(K, V) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- KSTREAM_DESERIALIZATION_RECOVERER - Static variable in class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
-
Property name for configuring the recoverer using properties.
L
- LATEST_ONLY - org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Commit the current offset during partition assignment when auto.offset.reset is 'latest'; transactional if so configured.
- LATEST_ONLY_NO_TX - org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Commit the current offset during partition assignment when auto.offset.reset is 'latest'; use consumer commit even when transactions are being used.
- level() - Method in annotation type org.springframework.kafka.test.condition.LogLevels
-
The Log4j level name to switch the categories to during the test.
- LevelsContainer(Map<Class<?>, Level>, Map<String, Level>) - Constructor for class org.springframework.kafka.test.utils.JUnitUtils.LevelsContainer
- lifecycleMonitor - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- ListenerContainerIdleEvent - Class in org.springframework.kafka.event
-
An event that is emitted when a container is idle if the container is configured to do so.
- ListenerContainerIdleEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>, boolean) - Constructor for class org.springframework.kafka.event.ListenerContainerIdleEvent
-
Construct an instance with the provided arguments.
- ListenerExecutionFailedException - Exception in org.springframework.kafka.listener
-
The listener specific
KafkaException
extension. - ListenerExecutionFailedException(String) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException
-
Construct an instance with the provided properties.
- ListenerExecutionFailedException(String, String, Throwable) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException
-
Construct an instance with the provided properties.
- ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException
-
Construct an instance with the provided properties.
- ListenerInvokingBatchErrorHandler - Interface in org.springframework.kafka.listener
-
A batch error handler that is capable of invoking the listener during error handling.
- ListenerType - Enum in org.springframework.kafka.listener
-
Defines the listener type.
- ListenerUtils - Class in org.springframework.kafka.listener
-
Listener utilities.
- listTopics() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- log(Supplier<CharSequence>) - Method in class org.springframework.kafka.support.LogIfLevelEnabled
- log(Supplier<CharSequence>, Throwable) - Method in class org.springframework.kafka.support.LogIfLevelEnabled
- Log4j2LevelAdjuster - Class in org.springframework.kafka.test.rule
-
A JUnit method @Rule that changes the logger level for a set of classes while a test method is running.
- Log4j2LevelAdjuster(Level, Class<?>...) - Constructor for class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
- logger - Variable in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- logger - Variable in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- logger - Variable in class org.springframework.kafka.core.KafkaTemplate
- logger - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- logger - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- logger - Variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- logger - Variable in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
- logger - Variable in class org.springframework.kafka.listener.FailedRecordProcessor
- logger - Variable in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
- logger - Variable in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
- logger - Variable in class org.springframework.kafka.support.converter.MessagingMessageConverter
- LoggingCommitCallback - Class in org.springframework.kafka.listener
-
Logs commit results at DEBUG level for success and ERROR for failures.
- LoggingCommitCallback() - Constructor for class org.springframework.kafka.listener.LoggingCommitCallback
- LoggingErrorHandler - Class in org.springframework.kafka.listener
-
The
ErrorHandler
implementation for logging purpose. - LoggingErrorHandler() - Constructor for class org.springframework.kafka.listener.LoggingErrorHandler
- LoggingProducerListener<K,V> - Class in org.springframework.kafka.support
-
The
ProducerListener
that logs exceptions thrown when sending messages. - LoggingProducerListener() - Constructor for class org.springframework.kafka.support.LoggingProducerListener
- LogIfLevelEnabled - Class in org.springframework.kafka.support
-
Wrapper for a commons-logging Log supporting configurable logging levels.
- LogIfLevelEnabled(LogAccessor, LogIfLevelEnabled.Level) - Constructor for class org.springframework.kafka.support.LogIfLevelEnabled
- LogIfLevelEnabled.Level - Enum in org.springframework.kafka.support
-
Logging levels.
- logLateArrival(ConsumerRecord<K, R>, CorrelationKey) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- LogLevels - Annotation Type in org.springframework.kafka.test.condition
-
Test classes annotated with this will change logging levels between tests.
- LogLevelsCondition - Class in org.springframework.kafka.test.condition
-
JUnit condition that adjusts and reverts log levels before/after each test.
- LogLevelsCondition() - Constructor for class org.springframework.kafka.test.condition.LogLevelsCondition
M
- MANUAL - org.springframework.kafka.listener.ContainerProperties.AckMode
-
User takes responsibility for acks using an
AcknowledgingMessageListener
. - MANUAL_IMMEDIATE - org.springframework.kafka.listener.ContainerProperties.AckMode
-
User takes responsibility for acks using an
AcknowledgingMessageListener
. - matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
- matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
- matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
- matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
- matches(String) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
- matches(String, Object) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
- matches(ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
- matches(ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition
- matches(ConsumerRecord<?, V>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition
- matches(ConsumerRecord<K, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition
- matches(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyValueCondition
- matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
- matchHeader(String) - Method in interface org.springframework.kafka.support.AbstractKafkaHeaderMapper.HeaderMatcher
-
Return true if the header matches.
- matchHeader(String) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher
- matchHeader(String) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
- MESSAGE_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the message key when sending data to Kafka.
- MessageConverter - Interface in org.springframework.kafka.support.converter
-
A top level interface for message converters.
- MessageListener<K,V> - Interface in org.springframework.kafka.listener
-
Listener for handling individual incoming Kafka messages.
- MessageListenerContainer - Interface in org.springframework.kafka.listener
-
Internal abstraction used by the framework representing a message listener container.
- MessagingFunction - Interface in org.springframework.kafka.streams.messaging
-
A function that receives a spring-messaging
Message
and returns aMessage
. - MessagingMessageConverter - Class in org.springframework.kafka.support.converter
-
A Messaging
MessageConverter
implementation for a message listener that receives individual messages. - MessagingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.MessagingMessageConverter
- MessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
-
An abstract
MessageListener
adapter providing the necessary infrastructure to extract the payload of aMessage
. - MessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter.ReplyExpressionRoot - Class in org.springframework.kafka.listener.adapter
-
Root object for reply expression evaluation.
- MessagingTransformer<K,V,R> - Class in org.springframework.kafka.streams.messaging
-
A
Transformer
implementation that invokes aMessagingFunction
converting to/from spring-messagingMessage
. - MessagingTransformer(MessagingFunction, MessagingMessageConverter) - Constructor for class org.springframework.kafka.streams.messaging.MessagingTransformer
- MethodKafkaListenerEndpoint<K,V> - Class in org.springframework.kafka.config
-
A
KafkaListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint. - MethodKafkaListenerEndpoint() - Constructor for class org.springframework.kafka.config.MethodKafkaListenerEndpoint
- metrics() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- metrics() - Method in interface org.springframework.kafka.core.KafkaOperations
-
See
Producer.metrics()
. - metrics() - Method in class org.springframework.kafka.core.KafkaTemplate
- metrics() - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- metrics() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- metrics() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
- metrics() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Return metrics kept by this container's consumer(s), grouped by
client-id
. - metricsFromConsumer() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- metricsFromProducer() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- MICROMETER_PRESENT - Static variable in class org.springframework.kafka.support.KafkaUtils
-
True if micrometer is on the class path.
- MicrometerConsumerListener<K,V> - Class in org.springframework.kafka.core
-
A consumer factory listener that manages
KafkaClientMetrics
. - MicrometerConsumerListener(MeterRegistry) - Constructor for class org.springframework.kafka.core.MicrometerConsumerListener
-
Construct an instance with the provided registry.
- MicrometerConsumerListener(MeterRegistry, List<Tag>) - Constructor for class org.springframework.kafka.core.MicrometerConsumerListener
-
Construct an instance with the provided registry and tags.
- MicrometerHolder - Class in org.springframework.kafka.support.micrometer
-
A wrapper for micrometer timers when available on the class path.
- MicrometerHolder(ApplicationContext, String, String, String, Map<String, String>) - Constructor for class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Create an instance with the provided properties.
- MicrometerProducerListener<K,V> - Class in org.springframework.kafka.core
-
A producer factory listener that manages
KafkaClientMetrics
. - MicrometerProducerListener(MeterRegistry) - Constructor for class org.springframework.kafka.core.MicrometerProducerListener
-
Construct an instance with the provided registry.
- MicrometerProducerListener(MeterRegistry, List<Tag>) - Constructor for class org.springframework.kafka.core.MicrometerProducerListener
-
Construct an instance with the provided registry and tags.
- MultiMethodKafkaListenerEndpoint<K,V> - Class in org.springframework.kafka.config
-
The
MethodKafkaListenerEndpoint
extension for several POJO methods based on theKafkaHandler
. - MultiMethodKafkaListenerEndpoint(List<Method>, Object) - Constructor for class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint
-
Construct an instance for the provided methods and bean with no default method.
- MultiMethodKafkaListenerEndpoint(List<Method>, Method, Object) - Constructor for class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint
-
Construct an instance for the provided methods, default method and bean.
N
- nack(int, long) - Method in interface org.springframework.kafka.support.Acknowledgment
-
Negatively acknowledge the record at an index in a batch - commit the offset(s) of records before the index and re-seek the partitions so that the record at the index and subsequent records will be redelivered after the sleep time.
- nack(long) - Method in interface org.springframework.kafka.support.Acknowledgment
-
Negatively acknowledge the current record - discard remaining records from the poll and re-seek all partitions so that this record will be redelivered after the sleep time.
- name(String) - Static method in class org.springframework.kafka.config.TopicBuilder
-
Create a TopicBuilder with the supplied name.
- NATIVE_HEADERS - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for holding the native headers of the consumer record; only provided if no header mapper is present.
- NEVER - org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Never commit the current offset during partition assignment.
- NeverMatchHeaderMatcher(String...) - Constructor for class org.springframework.kafka.support.AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher
- NonResponsiveConsumerEvent - Class in org.springframework.kafka.event
-
An event that is emitted when a consumer is not responding to the poll; a possible indication that the broker is down.
- NonResponsiveConsumerEvent(Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) - Constructor for class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
Deprecated.
- NonResponsiveConsumerEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) - Constructor for class org.springframework.kafka.event.NonResponsiveConsumerEvent
-
Construct an instance with the provided properties.
- NonTrustedHeaderType() - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- noTypeInfo() - Method in class org.springframework.kafka.support.serializer.JsonSerde
-
Configure the serializer to not add type information.
- noTypeInfo() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Do not include type info headers.
- NULL_MESSAGE - Static variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Message used when no conversion is needed.
O
- objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
- objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer
- offset() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for the partition offset.
- offsetsForTimes(Map<TopicPartition, Long>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- onApplicationEvent(ContextStoppedEvent) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- onApplicationEvent(ContextStoppedEvent) - Method in class org.springframework.kafka.core.KafkaTemplate
- onComplete(Map<TopicPartition, OffsetAndMetadata>, Exception) - Method in class org.springframework.kafka.listener.LoggingCommitCallback
- onError(ProducerRecord<K, V>, Exception) - Method in class org.springframework.kafka.support.CompositeProducerListener
- onError(ProducerRecord<K, V>, Exception) - Method in class org.springframework.kafka.support.LoggingProducerListener
- onError(ProducerRecord<K, V>, Exception) - Method in interface org.springframework.kafka.support.ProducerListener
-
Invoked after an attempt to send a message has failed.
- onFailure(Throwable) - Method in interface org.springframework.kafka.core.KafkaFailureCallback
- onFailure(KafkaProducerException) - Method in interface org.springframework.kafka.core.KafkaFailureCallback
-
Called when the send fails.
- onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
-
If the container is configured to emit idle container events, this method is called when the container idle event is emitted - allowing a seek operation.
- onMessage(List<ConsumerRecord<K, Collection<ConsumerRecord<K, R>>>>, Consumer<?, ?>) - Method in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
- onMessage(List<ConsumerRecord<K, R>>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- onMessage(List<ConsumerRecord<K, V>>) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
- onMessage(List<ConsumerRecord<K, V>>) - Method in interface org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener
-
Invoked with data from kafka.
- onMessage(List<ConsumerRecord<K, V>>) - Method in interface org.springframework.kafka.listener.BatchAcknowledgingMessageListener
-
Invoked with data from kafka.
- onMessage(List<ConsumerRecord<K, V>>) - Method in interface org.springframework.kafka.listener.BatchConsumerAwareMessageListener
-
Invoked with data from kafka.
- onMessage(List<ConsumerRecord<K, V>>, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
- onMessage(List<ConsumerRecord<K, V>>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.BatchConsumerAwareMessageListener
- onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
- onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - Method in interface org.springframework.kafka.listener.BatchAcknowledgingMessageListener
- onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Kafka
MessageListener
entry point. - onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
- onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.BatchAcknowledgingConsumerAwareMessageListener
- onMessage(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener
-
Invoked with data from kafka.
- onMessage(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.AcknowledgingMessageListener
-
Invoked with data from kafka.
- onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.ConsumerAwareMessageListener
-
Invoked with data from kafka.
- onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareMessageListener
- onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in interface org.springframework.kafka.listener.AcknowledgingMessageListener
-
Invoked with data from kafka.
- onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener
- onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
- onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter
-
Kafka
AcknowledgingConsumerAwareMessageListener
entry point. - onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
- onMessage(ConsumerRecords<K, V>, Acknowledgment, Consumer<K, V>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
- onMessage(ConsumerRecords<K, V>, Acknowledgment, Consumer<K, V>) - Method in interface org.springframework.kafka.listener.BatchMessageListener
-
Listener receives the original
ConsumerRecords
object instead of a list ofConsumerRecord
. - onMessage(T) - Method in interface org.springframework.kafka.listener.GenericMessageListener
-
Invoked with data from kafka.
- onMessage(T, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.GenericMessageListener
-
Invoked with data from kafka and provides access to the
Consumer
. - onMessage(T, Acknowledgment) - Method in interface org.springframework.kafka.listener.GenericMessageListener
-
Invoked with data from kafka.
- onMessage(T, Acknowledgment, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.GenericMessageListener
-
Invoked with data from kafka and provides access to the
Consumer
. - onPartitionsAssigned(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
- onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
- onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
-
When using group management, called when partition assignments change.
- onPartitionsAssigned(Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
-
The same as
ConsumerAwareRebalanceListener.onPartitionsAssigned(Collection)
with the additional consumer parameter. - onPartitionsLost(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
- onPartitionsLost(Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
-
The same as
ConsumerAwareRebalanceListener.onPartitionsLost(Collection)
with an additional consumer parameter. - onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
- onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
- onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- onPartitionsRevoked(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
- onPartitionsRevoked(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
-
When using group management, called when partition assignments are revoked.
- onPartitionsRevokedAfterCommit(Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
-
The same as
ConsumerAwareRebalanceListener.onPartitionsRevoked(Collection)
with the additional consumer parameter. - onPartitionsRevokedBeforeCommit(Consumer<?, ?>, Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerAwareRebalanceListener
-
The same as
ConsumerAwareRebalanceListener.onPartitionsRevoked(Collection)
with the additional consumer parameter. - onSuccess(ProducerRecord<K, V>, RecordMetadata) - Method in class org.springframework.kafka.support.CompositeProducerListener
- onSuccess(ProducerRecord<K, V>, RecordMetadata) - Method in interface org.springframework.kafka.support.ProducerListener
-
Invoked after the successful send of a message (that is, after it has been acknowledged by the broker).
- onTopOf(KStream<K, V>) - Method in class org.springframework.kafka.support.KafkaStreamBrancher
-
Terminating method that builds branches on top of given
KStream
. - OPTIONAL - org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
-
Optional - The
LoginModule
is not required to succeed. - org.springframework.kafka - package org.springframework.kafka
-
Base package for kafka
- org.springframework.kafka.annotation - package org.springframework.kafka.annotation
-
Package for kafka annotations
- org.springframework.kafka.config - package org.springframework.kafka.config
-
Package for kafka configuration
- org.springframework.kafka.core - package org.springframework.kafka.core
-
Package for kafka core components
- org.springframework.kafka.core.reactive - package org.springframework.kafka.core.reactive
-
Reactive component for consumer and producer.
- org.springframework.kafka.event - package org.springframework.kafka.event
-
Application Events.
- org.springframework.kafka.listener - package org.springframework.kafka.listener
-
Package for kafka listeners
- org.springframework.kafka.listener.adapter - package org.springframework.kafka.listener.adapter
-
Provides classes for adapting listeners.
- org.springframework.kafka.requestreply - package org.springframework.kafka.requestreply
-
Provides classes for request/reply semantics.
- org.springframework.kafka.security.jaas - package org.springframework.kafka.security.jaas
-
Provides classes related to jaas.
- org.springframework.kafka.streams - package org.springframework.kafka.streams
-
Package for classes related to Kafka Streams.
- org.springframework.kafka.streams.messaging - package org.springframework.kafka.streams.messaging
-
Package for classes related to spring-messaging with Kafka Streams.
- org.springframework.kafka.support - package org.springframework.kafka.support
-
Package for kafka support
- org.springframework.kafka.support.converter - package org.springframework.kafka.support.converter
-
Package for kafka converters
- org.springframework.kafka.support.micrometer - package org.springframework.kafka.support.micrometer
-
Provides classes to support Micrometer.
- org.springframework.kafka.support.serializer - package org.springframework.kafka.support.serializer
- org.springframework.kafka.test - package org.springframework.kafka.test
- org.springframework.kafka.test.assertj - package org.springframework.kafka.test.assertj
- org.springframework.kafka.test.condition - package org.springframework.kafka.test.condition
-
Provides classes for JUnit5 conditions.
- org.springframework.kafka.test.context - package org.springframework.kafka.test.context
- org.springframework.kafka.test.core - package org.springframework.kafka.test.core
- org.springframework.kafka.test.hamcrest - package org.springframework.kafka.test.hamcrest
- org.springframework.kafka.test.rule - package org.springframework.kafka.test.rule
- org.springframework.kafka.test.utils - package org.springframework.kafka.test.utils
- org.springframework.kafka.transaction - package org.springframework.kafka.transaction
-
Provides classes related to transactions.
P
- parentOrThis() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Return this or a parent container if this has a parent.
- parentOrThis() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
- parseBooleanProperty(String) - Static method in class org.springframework.kafka.test.utils.JUnitUtils
-
Return the parsed value if the provided property exists in the environment or system properties.
- PARSER_CONTEXT - Static variable in class org.springframework.kafka.listener.adapter.AdapterUtils
-
Parser context for runtime SpEL using ! as the template prefix.
- ParseStringDeserializer<T> - Class in org.springframework.kafka.support.serializer
-
Generic
Deserializer
for deserialization of entity from itsString
representation received from Kafka (a.k.a parsing). - ParseStringDeserializer() - Constructor for class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Construct an instance with no parser function; a static method name must be provided in the consumer config
ParseStringDeserializer.KEY_PARSER
orParseStringDeserializer.VALUE_PARSER
properties. - ParseStringDeserializer(BiFunction<String, Headers, T>) - Constructor for class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Construct an instance with the supplied parser function.
- ParseStringDeserializer(Function<String, T>) - Constructor for class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Construct an instance with the supplied parser function.
- PARTIAL_RESULTS_AFTER_TIMEOUT_TOPIC - Static variable in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
-
Pseudo topic name for the "outer"
ConsumerRecord
that has the aggregated results in its value after a timeout. - partition() - Method in annotation type org.springframework.kafka.annotation.PartitionOffset
-
The partition within the topic to listen on.
- partition() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- partition(int) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- PARTITION_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the topic partition when sending data to Kafka.
- PartitionOffset - Annotation Type in org.springframework.kafka.annotation
-
Used to add partition/initial offset information to a
KafkaListener
. - partitionOffsets() - Method in annotation type org.springframework.kafka.annotation.TopicPartition
-
The partitions with initial offsets within the topic.
- partitions() - Method in annotation type org.springframework.kafka.annotation.TopicPartition
-
The partitions within the topic.
- partitions() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
- partitions(int) - Method in class org.springframework.kafka.config.TopicBuilder
-
Set the number of partitions (default broker 'num.partitions').
- partitionsFor(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- partitionsFor(String) - Method in interface org.springframework.kafka.core.KafkaOperations
-
See
Producer.partitionsFor(String)
. - partitionsFor(String) - Method in class org.springframework.kafka.core.KafkaTemplate
- partitionsFromConsumerFor(String) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- partitionsFromProducerFor(String) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- pause() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- pause() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- pause() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Pause this container before the next poll().
- pause(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- paused() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- ports() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Set explicit ports on which the kafka brokers will listen.
- position(TopicPartition) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- PREFIX - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The prefix for Kafka headers.
- primary() - Method in class org.springframework.kafka.core.ABSwitchCluster
-
Use the primary cluster.
- process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean) - Method in interface org.springframework.kafka.listener.AfterRollbackProcessor
-
Deprecated.
- process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean) - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
-
Deprecated.
- process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean, ContainerProperties.EOSMode) - Method in interface org.springframework.kafka.listener.AfterRollbackProcessor
-
Process the remaining records.
- process(List<ConsumerRecord<K, V>>, Consumer<K, V>, Exception, boolean, ContainerProperties.EOSMode) - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
- processKafkaListener(KafkaListener, Method, Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- processListener(MethodKafkaListenerEndpoint<?, ?>, KafkaListener, Object, Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
- producerAdded(String, Producer<K, V>) - Method in class org.springframework.kafka.core.MicrometerProducerListener
- producerAdded(String, Producer<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory.Listener
-
A new producer was created.
- ProducerFactory<K,V> - Interface in org.springframework.kafka.core
-
The strategy to produce a
Producer
instance(s). - ProducerFactory.Listener<K,V> - Interface in org.springframework.kafka.core
-
Called whenever a producer is added or removed.
- ProducerFactoryUtils - Class in org.springframework.kafka.core
-
Helper class for managing a Spring based Kafka
DefaultKafkaProducerFactory
in particular for obtaining transactional Kafka resources for a given ProducerFactory. - ProducerListener<K,V> - Interface in org.springframework.kafka.support
-
Listener for handling outbound Kafka messages.
- ProducerPostProcessor<K,V> - Interface in org.springframework.kafka.core
-
Called by producer factories to perform post processing on newly created producers.
- producerProps(String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Set up test properties for an
<Integer, String>
producer. - producerProps(EmbeddedKafkaBroker) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
-
Set up test properties for an
<Integer, String>
producer. - producerRemoved(String, Producer<K, V>) - Method in class org.springframework.kafka.core.MicrometerProducerListener
- producerRemoved(String, Producer<K, V>) - Method in interface org.springframework.kafka.core.ProducerFactory.Listener
-
An exsting producer was removed.
- ProjectingMessageConverter - Class in org.springframework.kafka.support.converter
-
A
MessageConverter
implementation that uses a Spring DataProjectionFactory
to bind incoming messages to projection interfaces. - ProjectingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.ProjectingMessageConverter
-
Create a new
ProjectingMessageConverter
using aJacksonUtils.enhancedObjectMapper()
by default. - ProjectingMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.ProjectingMessageConverter
-
Create a new
ProjectingMessageConverter
using the givenObjectMapper
. - ProjectingMessageConverter(ObjectMapper, MessagingMessageConverter) - Constructor for class org.springframework.kafka.support.converter.ProjectingMessageConverter
-
Create a new
ProjectingMessageConverter
using the givenObjectMapper
. - ProjectingMessageConverter(MessagingMessageConverter) - Constructor for class org.springframework.kafka.support.converter.ProjectingMessageConverter
-
Create a new
ProjectingMessageConverter
using the givenObjectMapper
. - properties() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
Kafka consumer properties; they will supersede any properties with the same name defined in the consumer factory (if the consumer factory supports property overrides).
- propertyToMethodInvokingFunction(String, Class<P>, ClassLoader) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils
-
Convert a property value (FQCN.methodName) to a
BiFunction
that takes a payload and headers and returns some value. - publish(ProducerRecord<Object, Object>, KafkaOperations<Object, Object>) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Override this if you want more than just logging of the send result.
- publishContainerStoppedEvent() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
R
- RAW_DATA - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the raw data received from Kafka (
ConsumerRecord
orConsumerRecords
). - ReactiveKafkaConsumerTemplate<K,V> - Class in org.springframework.kafka.core.reactive
-
Reactive kafka consumer operations implementation.
- 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(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
- receiveAtMostOnce() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- receiveAutoAck() - 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_MESSAGE_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the message key for the received message.
- RECEIVED_PARTITION_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the topic partition for 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 - org.springframework.kafka.listener.ContainerProperties.AckMode
-
Commit 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 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 configurableHandlerAdapter
; 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
- recordToString(ConsumerRecord<?, ?>) - Static method in class org.springframework.kafka.listener.ListenerUtils
-
Return the
ConsumerRecord
as a String; eithertoString()
ortopic-partition@offset
. - recordToString(ConsumerRecord<?, ?>, boolean) - Static method in class org.springframework.kafka.listener.ListenerUtils
-
Return the
ConsumerRecord
as a String; eithertoString()
ortopic-partition@offset
. - RecoveringBatchErrorHandler - Class in org.springframework.kafka.listener
-
An error handler that seeks to the current offset for each topic in a batch of records.
- RecoveringBatchErrorHandler() - Constructor for class org.springframework.kafka.listener.RecoveringBatchErrorHandler
-
Construct an instance with the default recoverer which simply logs the record after 10 (maxFailures) have occurred for a topic/partition/offset.
- RecoveringBatchErrorHandler(BiConsumer<ConsumerRecord<?, ?>, Exception>) - Constructor for class org.springframework.kafka.listener.RecoveringBatchErrorHandler
-
Construct an instance with the provided recoverer which will be called after 10 (maxFailures) have occurred for a topic/partition/offset.
- RecoveringBatchErrorHandler(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - Constructor for class org.springframework.kafka.listener.RecoveringBatchErrorHandler
-
Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
- RecoveringBatchErrorHandler(BackOff) - Constructor for class org.springframework.kafka.listener.RecoveringBatchErrorHandler
-
Construct an instance with the default recoverer which simply logs the record after the backOff returns STOP for a topic/partition/offset.
- RecoveringDeserializationExceptionHandler - Class in org.springframework.kafka.streams
-
A
DeserializationExceptionHandler
that calls aConsumerRecordRecoverer
. - RecoveringDeserializationExceptionHandler() - Constructor for class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
- RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer) - Constructor for class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
- registerAllEndpoints() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
- registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.kafka.annotation.KafkaBootstrapConfiguration
- registerEndpoint(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Register a new
KafkaListenerEndpoint
using the defaultKafkaListenerContainerFactory
to create the underlying container. - registerEndpoint(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Register a new
KafkaListenerEndpoint
alongside theKafkaListenerContainerFactory
to use to create the underlying container. - 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() - Method in annotation type 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
- RemainingRecordsErrorHandler - Interface in org.springframework.kafka.listener
-
An error handler that has access to the unprocessed records from the last poll (including the failed record) and the consumer, for example to adjust offsets after an error.
- REMOVE_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property for removing type headers (default true).
- removeDelegate(String) - Method in class org.springframework.kafka.support.serializer.DelegatingDeserializer
- removeDelegate(String) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
- removeDelegate(ProducerListener<K, V>) - Method in class org.springframework.kafka.support.CompositeProducerListener
- removeHeaders(Headers) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- removeHeaders(Headers) - Method in interface org.springframework.kafka.support.converter.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.listener.FailedRecordProcessor
-
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.
- 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 class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
- 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
- RequestReplyFuture<K,V,R> - Class in org.springframework.kafka.requestreply
-
A listenable future for requests/replies.
- RequestReplyFuture() - Constructor for class org.springframework.kafka.requestreply.RequestReplyFuture
- REQUIRED - org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
-
Required - The
LoginModule
is required to succeed. - REQUISITE - 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 transactionalProducer
(s). - reset() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Reset any state in the factory, if supported.
- resolveParameter(ParameterContext, ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
- 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.EmbeddedKafkaBroker
- resume() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- resume() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- resume() - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Resume this container, if paused, after the next poll().
- resume(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- retrieveHeader(Headers, String) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- retrieveHeaderAsString(Headers, String) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- RetryingBatchErrorHandler - Class in org.springframework.kafka.listener
-
A batch error handler that invokes the listener according to the supplied
BackOff
. - RetryingBatchErrorHandler() - Constructor for class org.springframework.kafka.listener.RetryingBatchErrorHandler
-
Construct an instance with a default
FixedBackOff
(unlimited attempts with a 5 second back off). - RetryingBatchErrorHandler(BackOff, ConsumerRecordRecoverer) - Constructor for class org.springframework.kafka.listener.RetryingBatchErrorHandler
-
Construct an instance with the provided
BackOff
andConsumerRecordRecoverer
. - RetryingDeserializer<T> - Class in org.springframework.kafka.support.serializer
-
A deserialzer 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
- RetryingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
-
A retrying message listener adapter for
MessageListener
s. - RetryingMessageListenerAdapter(MessageListener<K, V>, RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
Construct an instance with the provided template and delegate.
- RetryingMessageListenerAdapter(MessageListener<K, V>, RetryTemplate, RecoveryCallback<? extends Object>) - Constructor for class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
Construct an instance with the provided template, callback and delegate.
- RetryingMessageListenerAdapter(MessageListener<K, V>, RetryTemplate, RecoveryCallback<? extends Object>, boolean) - Constructor for class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
-
Construct an instance with the provided template, callback and delegate.
- returnTypeMessageOrCollectionOf(Method) - Static method in class org.springframework.kafka.support.KafkaUtils
-
Return true if the method return type is
Message
orCollection<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.
S
- secondary() - Method in class org.springframework.kafka.core.ABSwitchCluster
-
Use the secondary cluster.
- seek(String, int, long) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek operation.
- seek(TopicPartition, long) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- seekOrRecover(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer, boolean, BiPredicate<ConsumerRecord<?, ?>, Exception>, LogAccessor, KafkaException.Level) - Static method in class org.springframework.kafka.listener.SeekUtils
-
Seek the remaining records, optionally recovering the first.
- seekPartitions(Consumer<?, ?>, Map<TopicPartition, Long>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils
-
Perform seek operations on each partition.
- seekRelative(String, int, long, boolean) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek relative to the start, end, or current position.
- seekToBeginning() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
Seek all assigned partitions to the beginning.
- seekToBeginning(String, int) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to beginning operation.
- seekToBeginning(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to beginning operation.
- seekToBeginning(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- SeekToCurrentBatchErrorHandler - Class in org.springframework.kafka.listener
-
An error handler that seeks to the current offset for each topic in a batch of records.
- SeekToCurrentBatchErrorHandler() - Constructor for class org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler
- SeekToCurrentErrorHandler - Class in org.springframework.kafka.listener
-
An error handler that seeks to the current offset for each topic in the remaining records.
- SeekToCurrentErrorHandler() - Constructor for class org.springframework.kafka.listener.SeekToCurrentErrorHandler
-
Construct an instance with the default recoverer which simply logs the record after 10 (maxFailures) have occurred for a topic/partition/offset.
- SeekToCurrentErrorHandler(BiConsumer<ConsumerRecord<?, ?>, Exception>) - Constructor for class org.springframework.kafka.listener.SeekToCurrentErrorHandler
-
Construct an instance with the provided recoverer which will be called after 10 (maxFailures) have occurred for a topic/partition/offset.
- SeekToCurrentErrorHandler(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - Constructor for class org.springframework.kafka.listener.SeekToCurrentErrorHandler
-
Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
- SeekToCurrentErrorHandler(BackOff) - Constructor for class org.springframework.kafka.listener.SeekToCurrentErrorHandler
-
Construct an instance with the default recoverer which simply logs the record after the backOff returns STOP for a topic/partition/offset.
- seekToEnd() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
Seek all assigned partitions to the end.
- seekToEnd(String, int) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to end operation.
- seekToEnd(Collection<TopicPartition>) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to end operation.
- seekToEnd(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- seekToTimestamp(long) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
-
Seek all assigned partitions to the offset represented by the timestamp.
- seekToTimestamp(String, int, long) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to the first offset greater than or equal to the time stamp.
- seekToTimestamp(Collection<TopicPartition>, long) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
-
Perform a seek to the first offset greater than or equal to the time stamp.
- SeekUtils - Class in org.springframework.kafka.listener
-
Seek utilities.
- selectImports(AnnotationMetadata) - Method in class org.springframework.kafka.annotation.KafkaListenerConfigurationSelector
- selfLog(String, LogAccessor) - Method in exception org.springframework.kafka.KafkaException
-
Log this exception at its log level.
- send(String, int, long, K, V) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(String, int, K, V) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(String, Integer, Long, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with the provided key and partition.
- send(String, Integer, Long, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(String, Integer, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with the provided key and partition.
- send(String, Integer, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(String, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with the provided key and no partition.
- send(String, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(String, K, V) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(String, Message<?>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(String, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with no key or partition.
- send(String, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(String, V) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(ProducerRecord<K, V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- send(ProducerRecord<K, V>) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the provided
ProducerRecord
. - send(ProducerRecord<K, V>) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(ProducerRecord<K, V>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(ProducerRecord<K, V>, Callback) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- send(Publisher<? extends SenderRecord<K, V, T>>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- send(Message<?>) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send a message with routing information in message headers.
- send(Message<?>) - Method in class org.springframework.kafka.core.KafkaTemplate
- send(SenderRecord<K, V, T>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- sendAndReceive(ProducerRecord<K, V>) - Method in interface org.springframework.kafka.requestreply.ReplyingKafkaOperations
-
Send a request and receive a reply with the default timeout.
- sendAndReceive(ProducerRecord<K, V>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- sendAndReceive(ProducerRecord<K, V>, Duration) - Method in interface org.springframework.kafka.requestreply.ReplyingKafkaOperations
-
Send a request and receive a reply.
- sendAndReceive(ProducerRecord<K, V>, Duration) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- sendDefault(Integer, Long, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with the provided key and partition.
- sendDefault(Integer, Long, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendDefault(Integer, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with the provided key and partition.
- sendDefault(Integer, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendDefault(K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with the provided key and no partition.
- sendDefault(K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendDefault(V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with no key or partition.
- sendDefault(V) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>) - Method in interface org.springframework.kafka.core.KafkaOperations
-
When running in a transaction, send the consumer offset(s) to the transaction.
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in interface org.springframework.kafka.core.KafkaOperations
-
When running in a transaction, send the consumer offset(s) to the transaction.
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - Method in interface org.springframework.kafka.core.KafkaOperations
-
When running in a transaction, send the consumer offset(s) to the transaction.
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - Method in class org.springframework.kafka.core.KafkaTemplate
- sendResponse(Object, String, Object, boolean) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Send the result to the topic.
- SendResult<K,V> - Class in org.springframework.kafka.support
-
Result for a ListenableFuture after a send.
- SendResult(ProducerRecord<K, V>, RecordMetadata) - Constructor for class org.springframework.kafka.support.SendResult
- sendTransactionally(Publisher<? extends SenderRecord<K, V, T>>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- sendTransactionally(SenderRecord<K, V, T>) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- SERIALIZATION_SELECTOR - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Deprecated.in favor of
DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR
. - SERIALIZATION_SELECTOR_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingDeserializer
- SERIALIZATION_SELECTOR_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Deprecated.
- SerializationUtils - Class in org.springframework.kafka.support.serializer
-
Utilities for serialization.
- serialize(String, Object) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
- serialize(String, Object) - Method in class org.springframework.kafka.support.serializer.StringOrBytesSerializer
- serialize(String, Headers, Object) - Method in class org.springframework.kafka.support.serializer.DelegatingSerializer
- serialize(String, Headers, T) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
- serialize(String, Headers, T) - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
- serialize(String, T) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
- serialize(String, T) - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
- serializedKeySize() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- serializedValueSize() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- serializer() - Method in class org.springframework.kafka.support.serializer.JsonSerde
- serializer() - Method in class org.springframework.kafka.support.serializer.ToFromStringSerde
- setAckAfterHandle(boolean) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Set to false to prevent the container from committing the offset of a recovered record (when the error handler does not itself throw an exception).
- setAckAfterHandle(boolean) - Method in class org.springframework.kafka.listener.RecoveringBatchErrorHandler
- setAckAfterHandle(boolean) - Method in class org.springframework.kafka.listener.RetryingBatchErrorHandler
- setAckAfterHandle(boolean) - Method in class org.springframework.kafka.listener.SeekToCurrentErrorHandler
- setAckCount(int) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the number of outstanding record count after which offsets should be committed when
ContainerProperties.AckMode.COUNT
orContainerProperties.AckMode.COUNT_TIME
is being used. - setAckDiscarded(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set to true if the
AbstractKafkaListenerEndpoint.setRecordFilterStrategy(RecordFilterStrategy)
is in use. - setAckDiscarded(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set to true to ack discards when a filter strategy is in use.
- setAckMode(ContainerProperties.AckMode) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the ack mode to use when auto ack (in the configuration properties) is false.
- setAckOnError(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Deprecated.in favor of
GenericErrorHandler.isAckAfterHandle()
. - setAckTime(long) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the time (ms) after which outstanding offsets should be committed when
ContainerProperties.AckMode.TIME
orContainerProperties.AckMode.COUNT_TIME
is being used. - setAddTypeInfo(boolean) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Set to false to disable adding type info headers.
- setAddTypeInfo(boolean) - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Set to false to disable adding type info headers.
- setAdminTimeout(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set the timeout in seconds for admin operations (e.g.
- setAdviceChain(Advice...) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set a chain of listener
Advice
s; must not be null or have null elements. - setAfterRollbackProcessor(AfterRollbackProcessor<? super K, ? super V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a processor to invoke after a transaction rollback; typically will seek the unprocessed topic/partition to reprocess the records.
- setAfterRollbackProcessor(AfterRollbackProcessor<? super K, ? super V>) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Set a processor to perform seeks on unprocessed records after a rollback.
- setAllowNonTransactional(boolean) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set to true to allow a non-transactional send when the template is transactional.
- setAlwaysClientIdSuffix(boolean) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
Set to false to suppress adding a suffix to the child container's client.id when the concurrency is only 1.
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.core.KafkaAdmin
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.core.KafkaTemplate
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setAssignmentCommitOption(ContainerProperties.AssignmentCommitOption) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the assignment commit option.
- setAuthorizationExceptionRetryInterval(Duration) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the interval between retries after
AuthorizationException
is thrown byKafkaConsumer
. - setAutoCreate(boolean) - Method in class org.springframework.kafka.core.KafkaAdmin
-
Set to false to suppress auto creation of topics during context initialization.
- setAutoStartup(boolean) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setAutoStartup(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setAutoStartup(boolean) - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Set the autoStartup.
- setAutoStartup(boolean) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- setAutoStartup(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify an
autoStartup boolean
flag. - setAutoStartup(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the autoStartup for this endpoint's container.
- setBackOff(BackOff) - Method in class org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler
-
Set a
BackOff
to suspend the thread after performing the seek. - setBackOffFunction(BiFunction<ConsumerRecord<?, ?>, Exception, BackOff>) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Set a function to dynamically determine the
BackOff
to use, based on the consumer record and/or exception. - setBatchErrorHandler(BatchErrorHandler) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set the batch error handler to call when the listener throws an exception.
- setBatchErrorHandler(BatchErrorHandler) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Set the batch error handler to call when the listener throws an exception.
- setBatchListener(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set to true if this endpoint should create a batch listener.
- setBatchListener(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set to true if this endpoint should create a batch listener.
- setBatchMessageConverter(BatchMessageConverter) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Set the BatchMessageConverter.
- setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a
BatchToRecordAdapter
. - setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set a
BatchToRecordAdapter
. - setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
-
Set a
BatchToRecordAdapter
. - setBean(Object) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the object instance that should manage this endpoint.
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Making a
BeanFactory
available is optional; if not set,KafkaListenerConfigurer
beans won't get autodetected and anendpoint registry
has to be explicitly configured. - setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
A
BeanFactory
only needs to be available in conjunction withKafkaListenerEndpointRegistrar.setContainerFactoryBeanName(java.lang.String)
. - setBeanName(String) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setBeanName(String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
- setBeanName(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- setBeanName(String) - Method in class org.springframework.kafka.core.KafkaTemplate
- setBeanName(String) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setBeanResolver(BeanResolver) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set a bean resolver for runtime SpEL expressions.
- setBootstrapServersSupplier(Supplier<String>) - Method in class org.springframework.kafka.core.KafkaResourceFactory
-
Set a supplier for the bootstrap server list to override any configured in a subclass.
- setCharset(Charset) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Set a charset to use when converting byte[] to String in method arguments.
- setCharset(Charset) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Set the charset to use when mapping String-valued headers to/from byte[].
- setCharset(Charset) - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Set a charset to use when converting byte[] to
String
. - setCharset(Charset) - Method in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Set a charset to use when converting
String
to byte[]. - setClassIdFieldName(String) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Configure header name for type information.
- setClassifications(Map<Class<? extends Throwable>, Boolean>, boolean) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Set an exception classifications to determine whether the exception should cause a retry (until exhaustion) or not.
- setClientId(String) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the client id; overrides the consumer factory client.id property.
- setClientIdPrefix(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the client id prefix; overrides the client id in the consumer configuration properties.
- setClientIdSuffix(String) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Set a suffix to add to the
client.id
consumer property (if the consumer factory supports it). - setClientSupplier(KafkaClientSupplier) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setCloseTimeout(int) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Specify the timeout in seconds for the
KafkaStreams.close(Duration)
operation. - setCloseTimeout(int) - Method in class org.springframework.kafka.core.KafkaAdmin
-
Set the close timeout in seconds.
- setCloseTimeout(Duration) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set the maximum time to wait when closing a producer; default 5 seconds.
- setCloseTimeout(Duration) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
-
Set the maximum time to wait when closing a producer; default 5 seconds.
- setCommitCallback(OffsetCommitCallback) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the commit callback; by default a simple logging callback is used to log success at DEBUG level and failures at ERROR level.
- setCommitLogLevel(LogIfLevelEnabled.Level) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the level at which to log offset commits.
- setCommitRecovered(boolean) - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
-
Deprecated.
- setCommitRecovered(boolean) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Set to true to commit the offset for a recovered record.
- setCommitRecovered(boolean) - Method in class org.springframework.kafka.listener.SeekToCurrentErrorHandler
-
Set to true to commit the offset for a recovered record.
- setCommitRetries(int) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set number of retries allowed when a
RetriableCommitFailedException
is thrown by the consumer. - setCommitTimeout(Duration) - Method in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
-
Set the timeout to use when committing offsets.
- setConcurrency(int) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
The maximum number of concurrent
KafkaMessageListenerContainer
s running. - setConcurrency(Integer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the concurrency for this endpoint's container.
- setConcurrency(Integer) - Method in class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
-
Specify the container concurrency.
- setConsumerFactory(ConsumerFactory<? super K, ? super V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify a
ConsumerFactory
to use. - setConsumerGroupId(String) - Static method in class org.springframework.kafka.support.KafkaUtils
-
Set the group id for the consumer bound to this thread.
- setConsumerProperties(Properties) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
- setConsumerRebalanceListener(ConsumerRebalanceListener) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the user defined
ConsumerRebalanceListener
implementation. - setConsumerStartTimout(Duration) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the timeout to wait for a consumer thread to start before logging an error.
- setConsumerTaskExecutor(AsyncListenableTaskExecutor) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the executor for threads that poll the consumer.
- setContainerCustomizer(ContainerCustomizer<K, V, C>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a customizer used to further configure a container after it has been created.
- setContainerFactory(KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the
KafkaListenerContainerFactory
to use in case aKafkaListenerEndpoint
is registered with anull
container factory. - setContainerFactoryBeanName(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the bean name of the
KafkaListenerContainerFactory
to use in case aKafkaListenerEndpoint
is registered with anull
container factory. - setContentClassIdFieldName(String) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Configure header name for container object contents type information.
- setControlFlag(KafkaJaasLoginModuleInitializer.ControlFlag) - Method in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
- setCorrelationHeaderName(String) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set a custom header name for the correlation id.
- setCorrelationIdStrategy(Function<ProducerRecord<K, V>, CorrelationKey>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set a function to be called to establish a unique correlation key for each request record.
- setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver...) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Add custom methods arguments resolvers to
KafkaListenerAnnotationBeanPostProcessor
Default empty list. - setDefaultContainerFactoryBeanName(String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Set the name of the
KafkaListenerContainerFactory
to use by default. - setDefaultReplyTimeout(Duration) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set the reply timeout used if no replyTimeout is provided in the
ReplyingKafkaTemplate.sendAndReceive(ProducerRecord, Duration)
call. - setDefaultTopic(String) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set the default topic for send methods where a topic is not provided.
- setDelegates(ProducerListener<K, V>...) - Method in class org.springframework.kafka.support.CompositeProducerListener
- setDeliveryAttemptHeader(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set to true to populate the
KafkaHeaders.DELIVERY_ATTEMPT
header when the error handler or after rollback processor implementsDeliveryAttemptAware
. - setEmergencyStop(Runnable) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Set a
Runnable
to call whenever anError
occurs on a listener thread. - setEncodeStrings(boolean) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Set to true to encode String-valued headers as JSON ("..."), by default just the raw String value is converted to a byte array using the configured charset.
- setEndpointRegistry(KafkaListenerEndpointRegistry) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Set the
KafkaListenerEndpointRegistry
that will hold the created endpoint and manage the lifecycle of the related listener container. - setEndpointRegistry(KafkaListenerEndpointRegistry) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the
KafkaListenerEndpointRegistry
instance to use. - setEosMode(ContainerProperties.EOSMode) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the exactly once semantics mode.
- setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set the error handler to call when the listener throws an exception.
- setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Set the error handler to call when the listener throws an exception.
- setErrorHandler(KafkaListenerErrorHandler) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the
KafkaListenerErrorHandler
to invoke if the listener method throws an exception. - setFailedDeserializationFunction(Function<FailedDeserializationInfo, T>) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Provide an alternative supplying mechanism when deserialization fails.
- setFallbackType(Class<?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set a fallback type to use when using a type-aware message converter and this adapter cannot determine the inferred type from the method.
- setFatalIfBrokerNotAvailable(boolean) - Method in class org.springframework.kafka.core.KafkaAdmin
-
Set to true if you want the application context to fail to load if we are unable to connect to the broker during initialization, to check/add topics.
- setFixTxOffsets(boolean) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
When consuming records produced by a transactional producer, and the consumer is positioned at the end of a partition, the lag can incorrectly be reported as greater than zero, due to the pseudo record used to indicate transaction commit/rollback and, possibly, the presence of rolled-back records.
- setForKey(boolean) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Set to true if this deserializer is to be used as a key deserializer when configuring outside of Kafka.
- setGenerateMessageId(boolean) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Generate
Message
ids
for produced messages. - setGenerateMessageId(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Generate
Message
ids
for produced messages. - setGenerateTimestamp(boolean) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Generate
timestamp
for produced messages. - setGenerateTimestamp(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Generate
timestamp
for produced messages. - setGenericErrorHandler(GenericErrorHandler<?>) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Set the error handler to call when the listener throws an exception.
- setGroup(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the group for the corresponding listener container.
- setGroupId(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the group id to override the
group.id
property in the ContainerFactory. - setGroupId(String) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the group id for this container.
- setHandlerMethod(HandlerAdapter) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the
HandlerAdapter
to use to invoke the method processing an incomingConsumerRecord
. - setHeaderMapper(KafkaHeaderMapper) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
-
Set the header mapper to map headers.
- setHeaderMapper(KafkaHeaderMapper) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Set the header mapper to map headers.
- setHeaders(Headers) - Method in exception org.springframework.kafka.support.serializer.DeserializationException
-
Set the headers.
- setHeadersFunction(BiFunction<ConsumerRecord<?, ?>, Exception, Headers>) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Set a function which will be called to obtain additional headers to add to the published record.
- setHeaderValue(byte[]) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- setId(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- setIdClassMapping(Map<String, Class<?>>) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
- setIdleBetweenPolls(long) - Method in class org.springframework.kafka.listener.ContainerProperties
-
The sleep interval in milliseconds used in the main loop between
Consumer.poll(Duration)
calls. - setIdleEventInterval(Long) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the idle event interval; when set, an event is emitted if a poll returns no records and this interval has elapsed since a record was returned.
- setIncludeContents(boolean) - Method in class org.springframework.kafka.support.LoggingProducerListener
-
Whether the log message should include the contents (key and payload).
- setInfrastructureCustomizer(KafkaStreamsInfrastructureCustomizer) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Set a customizer to configure the builder and/or topology before creating the stream.
- setInterceptBeforeTx(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
When true, invoke the interceptor before the transaction starts.
- setKafkaConsumerProperties(Properties) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
- setKafkaOperations(KafkaOperations<K, V>) - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
-
Deprecated.
- setKafkaStreamsCustomizer(KafkaStreamsCustomizer) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Specify a
KafkaStreamsCustomizer
to customize aKafkaStreams
instance duringStreamsBuilderFactoryBean.start()
. - setKafkaTemplate(KafkaTemplate<K, V>) - Method in class org.springframework.kafka.listener.DefaultAfterRollbackProcessor
-
Deprecated.
- setKeyClassIdFieldName(String) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Configure header name for map key type information.
- setKeyDeserializer(Deserializer<K>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Set the key deserializer.
- setKeySerializer(Serializer<K>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Set a key serializer.
- setLogContainerConfig(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set to true to instruct each container to log this configuration.
- setLoginModule(String) - Method in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
- setLogLevel(KafkaException.Level) - Method in class org.springframework.kafka.listener.KafkaExceptionLogLevelAware
-
Set the level at which the exception thrown by this handler is logged.
- setLogOnlyMetadata(boolean) - Static method in class org.springframework.kafka.listener.ListenerUtils
-
Set to true to only log record metadata.
- setMapAllStringsOut(boolean) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Set to true to map all
String
valued outbound headers tobyte[]
. - setMaxContentLogged(int) - Method in class org.springframework.kafka.support.LoggingProducerListener
-
The maximum amount of data to be logged for either key or password.
- setMessageConverter(MessageConverter) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set the message converter to use if dynamic argument type matching is needed.
- setMessageConverter(RecordMessageConverter) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set the message converter to use.
- setMessageConverter(RecordMessageConverter) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the MessageConverter.
- setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Set the
MessageHandlerMethodFactory
to use to configure the message listener responsible to serve an endpoint detected by this processor. - setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the
MessageHandlerMethodFactory
to use to configure the message listener responsible to serve an endpoint detected by this processor. - setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the
MessageHandlerMethodFactory
to use to build theInvocableHandlerMethod
responsible to manage the invocation of this endpoint. - setMessageListener(Object) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the message listener; must be a
MessageListener
orAcknowledgingMessageListener
. - setMethod(Method) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the method to invoke to process a message managed by this endpoint.
- setMicrometerEnabled(boolean) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set to false to disable micrometer timers, if micrometer is on the class path.
- setMicrometerEnabled(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set to false to disable the Micrometer listener timers.
- setMicrometerTags(Map<String, String>) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set additional tags for the Micrometer listener timers.
- setMicrometerTags(Map<String, String>) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set additional tags for the Micrometer listener timers.
- setMissingTopicsFatal(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set to false to allow the container to start even if any of the configured topics are not present on the broker.
- setMissingTopicsFatal(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set to false to allow the container to start even if any of the configured topics are not present on the broker.
- setMonitorInterval(int) - Method in class org.springframework.kafka.listener.ContainerProperties
-
The interval between checks for a non-responsive consumer in seconds; default 30.
- setNoPollThreshold(float) - Method in class org.springframework.kafka.listener.ContainerProperties
-
If the time since the last poll /
poll timeout
exceeds this value, a NonResponsiveConsumerEvent is published. - setOffset(Long) - Method in class org.springframework.kafka.support.TopicPartitionOffset
-
Set the offset.
- setOnlyLogRecordMetadata(boolean) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set to true to only log
topic-partition@offset
in log messages instead ofrecord.toString()
. - setOperationTimeout(int) - Method in class org.springframework.kafka.core.KafkaAdmin
-
Set the operation timeout in seconds.
- setOptions(Map<String, String>) - Method in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer
- setPhase(int) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify a
phase
to use. - setPhase(int) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setPhase(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setPhase(int) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- setPhysicalCloseTimeout(int) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
The time to wait when physically closing the producer via the factory rather than closing the producer itself (when
DefaultKafkaProducerFactory.reset()
,#closeProducerFor(String)
, orDefaultKafkaProducerFactory.closeThreadBoundProducer()
are invoked). - setPollTimeout(long) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the max time to block in the consumer waiting for records.
- setProducerListener(ProducerListener<K, V>) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set a
ProducerListener
which will be invoked when Kafka acknowledges a send operation. - setProducerPerConsumerPartition(boolean) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Set to false to revert to the previous behavior of a simple incrementing transactional.id suffix for each producer instead of maintaining a producer for each group/topic/partition.
- setProducerPerThread(boolean) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Set to true to create a producer per thread instead of singleton that is shared by all clients.
- setRawMappedHeaders(Map<String, Boolean>) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Set the headers to not perform any conversion on (except
String
tobyte[]
for outbound). - setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set the record filter strategy.
- setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set a
RecordFilterStrategy
implementation. - setRecordInterceptor(RecordInterceptor<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set an interceptor to be called before calling the listener.
- setRecordInterceptor(RecordInterceptor<K, V>) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Set an interceptor to be called before calling the listener.
- setRecoveryCallback(RecoveryCallback<? extends Object>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a callback to be used with the
retryTemplate
. - setRecoveryCallback(RecoveryCallback<? extends Object>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set a callback to be used with the
AbstractKafkaListenerEndpoint.setRetryTemplate(RetryTemplate)
. - setRelativeToCurrent(boolean) - Method in class org.springframework.kafka.support.TopicPartitionOffset
-
Set whether the offset is relative to the current position.
- setRemoveTypeHeaders(boolean) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set to false to retain type information headers after deserialization.
- setReplyHeadersConfigurer(ReplyHeadersConfigurer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a configurer which will be invoked when creating a reply message.
- setReplyHeadersConfigurer(ReplyHeadersConfigurer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set a configurer which will be invoked when creating a reply message.
- setReplyHeadersConfigurer(ReplyHeadersConfigurer) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set a configurer which will be invoked when creating a reply message.
- setReplyPartitionHeaderName(String) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set a custom header name for the reply partition.
- setReplyTemplate(KafkaTemplate<?, ?>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set the
KafkaTemplate
to use to send replies. - setReplyTemplate(KafkaTemplate<?, ?>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the
KafkaTemplate
to use to send replies. - setReplyTemplate(KafkaTemplate<?, ?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the template to use to send any result from the method invocation.
- setReplyTopic(String) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the topic to which to send any result from the method invocation.
- setReplyTopicHeaderName(String) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set a custom header name for the reply topic.
- setResetStateOnRecoveryFailure(boolean) - Method in class org.springframework.kafka.listener.FailedRecordProcessor
-
Set to false to immediately attempt to recover on the next attempt instead of repeating the BackOff cycle when recovery fails.
- setRetainExceptionHeader(boolean) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer
-
Set to true to retain a Java serialized
DeserializationException
header. - setRetryTemplate(RetryTemplate) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Set a retryTemplate.
- setRetryTemplate(RetryTemplate) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set a retryTemplate.
- setReturnPartialOnTimeout(boolean) - Method in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
-
Set to true to return a partial result when a request times out.
- setRunning(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setScheduler(TaskScheduler) - Method in class org.springframework.kafka.listener.ContainerProperties
-
A scheduler used with the monitor interval.
- setSendFuture(ListenableFuture<SendResult<K, V>>) - Method in class org.springframework.kafka.requestreply.RequestReplyFuture
- setSharedReplyTopic(boolean) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Set to true when multiple templates are using the same topic for replies.
- setShutdownTimeout(long) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the timeout for shutting down the container.
- setSplitIterables(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set to false to disable splitting
Iterable
reply values into separate records. - setSplitIterables(boolean) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set to false to disable splitting
Iterable
reply values into separate records. - setStatefulRetry(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
When using a
RetryTemplate
Set to true to enable stateful retry. - setStatefulRetry(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
When using a
RetryTemplate
, set to true to enable stateful retry. - setStateListener(KafkaStreams.StateListener) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setStateRestoreListener(StateRestoreListener) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setStreamsConfiguration(Properties) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Set the streams configuration
Properties
on this factory. - setSubBatchPerPartition(boolean) - Method in class org.springframework.kafka.listener.ContainerProperties
-
When using a batch message listener whether to dispatch records by partition (with a transaction for each sub batch if transactions are in use) or the complete batch received by the
poll()
. - setSyncCommits(boolean) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set whether or not to call consumer.commitSync() or commitAsync() when the container is responsible for commits.
- setSyncCommitTimeout(Duration) - Method in class org.springframework.kafka.listener.ConsumerProperties
-
Set the timeout for commitSync operations (if
ConsumerProperties.isSyncCommits()
. - setSyncCommitTimeout(Duration) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the timeout for commitSync operations (if
ConsumerProperties.isSyncCommits()
. - setTaskScheduler(TaskScheduler) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- setTopicCheckTimeout(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
How long to wait for
Admin.describeTopics(Collection)
result futures to complete. - setTopicPartitions(TopicPartitionOffset...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topicPartitions to use.
- setTopicPattern(Pattern) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topic pattern to use.
- setTopics(String...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topics to use.
- setTransactionDefinition(TransactionDefinition) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set a transaction definition with properties (e.g.
- setTransactionIdPrefix(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Set a prefix for the
ProducerConfig.TRANSACTIONAL_ID_CONFIG
config. - setTransactionIdPrefix(String) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set a transaction id prefix to override the prefix in the producer factory.
- setTransactionIdPrefix(String) - Method in class org.springframework.kafka.transaction.KafkaTransactionManager
-
Set a transaction id prefix to override the prefix in the producer factory.
- setTransactionIdSuffix(String) - Static method in class org.springframework.kafka.support.TransactionSupport
- setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.kafka.listener.ContainerProperties
-
Set the transaction manager to start a transaction; offsets are committed with semantics equivalent to
ContainerProperties.AckMode.RECORD
andContainerProperties.AckMode.BATCH
depending on the listener type (record or batch). - setTypeFunction(BiFunction<byte[], Headers, JavaType>) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set a
BiFunction
that receives the data to be deserialized and the headers and returns a JavaType. - setTypeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
-
Set a customized type mapper.
- setTypeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set a customized type mapper.
- setTypeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Set a customized type mapper.
- setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - Method in interface org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
-
Set the precedence for evaluating type information in message properties.
- setTypeResolver(JsonTypeResolver) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set a
JsonTypeResolver
that receives the data to be deserialized and the headers and returns a JavaType. - setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- setUntrustedType(String) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- setupDelegate(Map<String, ?>, String) - Method in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
- setupListenerContainer(MessageListenerContainer, MessageConverter) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- setupListenerContainer(MessageListenerContainer, MessageConverter) - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Setup the specified message listener container with the model defined by this endpoint.
- setupMessageListener(Object) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- setupMessageListener(Object) - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Setup the message listener to use.
- setUseForKey(boolean) - Method in class org.springframework.kafka.support.converter.AbstractJavaTypeMapper
-
Configure the TypeMapper to use default key type class.
- setUseTypeHeaders(boolean) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set to false to ignore type information in headers and use the configured target type instead.
- setUseTypeMapperForKey(boolean) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Configure the default Jackson2JavaTypeMapper to use key type headers.
- setUseTypeMapperForKey(boolean) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Configure the default Jackson2JavaTypeMapper to use key type headers.
- setValidator(Validator) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the validator to use if the default message handler factory is used.
- setValueDeserializer(Deserializer<V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
-
Set the value deserializer.
- setValueSerializer(Serializer<V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
Set a value serializer.
- setZkPort(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set the port to run the embedded Zookeeper on (default random).
- shouldCopy(String, Object) - Method in interface org.springframework.kafka.listener.adapter.ReplyHeadersConfigurer
-
Return true if the header should be copied to the reply message.
- shutdown() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper
- SIMPLE - org.springframework.kafka.listener.ListenerType
-
Simple.
- SimpleKafkaHeaderMapper - Class in org.springframework.kafka.support
-
A simple header mapper that maps headers directly; for outbound, only byte[] headers are mapped; for inbound, headers are mapped unchanged, as byte[].
- SimpleKafkaHeaderMapper() - Constructor for class org.springframework.kafka.support.SimpleKafkaHeaderMapper
-
Construct an instance with the default object mapper and default header patterns for outbound headers; all inbound headers are mapped.
- SimpleKafkaHeaderMapper(String...) - Constructor for class org.springframework.kafka.support.SimpleKafkaHeaderMapper
-
Construct an instance with a default object mapper and the provided header patterns for outbound headers; all inbound headers are mapped.
- SimplePatternBasedHeaderMatcher(String) - Constructor for class org.springframework.kafka.support.AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
- splitIterables() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
When false and the return type is a
Iterable
return the result as the value of a single reply record instead of individual records for each element. - SPRING_EMBEDDED_KAFKA_BROKERS - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
- SPRING_EMBEDDED_ZOOKEEPER_CONNECT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
- start() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- start() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- start() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- start() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- start() - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Start the timer.
- stop() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- stop() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- stop() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- stop() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- stop(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Stop the container.
- stop(Runnable) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
- stop(Runnable) - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
- stop(Runnable) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
- stop(Runnable) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
- streamsAdded(String, KafkaStreams) - Method in interface org.springframework.kafka.config.StreamsBuilderFactoryBean.Listener
-
A new
KafkaStreams
was created. - streamsAdded(String, KafkaStreams) - Method in class org.springframework.kafka.streams.KafkaStreamsMicrometerListener
- StreamsBuilderFactoryBean - Class in org.springframework.kafka.config
-
An
AbstractFactoryBean
for theStreamsBuilder
instance and lifecycle control for the internalKafkaStreams
instance. - StreamsBuilderFactoryBean() - Constructor for class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Default constructor that creates the factory without configuration
Properties
. - StreamsBuilderFactoryBean(KafkaStreamsConfiguration) - Constructor for class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Construct an instance with the supplied streams configuration.
- StreamsBuilderFactoryBean(KafkaStreamsConfiguration, CleanupConfig) - Constructor for class org.springframework.kafka.config.StreamsBuilderFactoryBean
-
Construct an instance with the supplied streams configuration and clean up configuration.
- StreamsBuilderFactoryBean.Listener - Interface in org.springframework.kafka.config
-
Called whenever a
KafkaStreams
is added or removed. - StreamsBuilderFactoryBeanCustomizer - Interface in org.springframework.kafka.config
-
A customizer for the
StreamsBuilderFactoryBean
that is implicitly created byEnableKafkaStreams
. - streamsRemoved(String, KafkaStreams) - Method in interface org.springframework.kafka.config.StreamsBuilderFactoryBean.Listener
-
An existing
KafkaStreams
was removed. - streamsRemoved(String, KafkaStreams) - Method in class org.springframework.kafka.streams.KafkaStreamsMicrometerListener
- StringJsonMessageConverter - Class in org.springframework.kafka.support.converter
-
JSON Message converter - String on output, String, Bytes, or byte[] on input.
- StringJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.StringJsonMessageConverter
- StringJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.StringJsonMessageConverter
- StringOrBytesSerializer - Class in org.springframework.kafka.support.serializer
-
A serializer that can handle
byte[]
,Bytes
andString
. - StringOrBytesSerializer() - Constructor for class org.springframework.kafka.support.serializer.StringOrBytesSerializer
- subscription() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate
- success(Object) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Record success.
- SUFFICIENT - org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
-
Sufficient - The
LoginModule
is not required to succeed. - supportsParameter(ParameterContext, ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
T
- targetType - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
- TIME - org.springframework.kafka.listener.ContainerProperties.AckMode
-
Commit pending updates after
ackTime
has elapsed. - timestamp() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- timestamp(long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- timestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- TIMESTAMP - org.springframework.kafka.support.TopicPartitionOffset.SeekPosition
-
Seek to the time stamp.
- TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for holding the timestamp of the producer record.
- TIMESTAMP_TYPE - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header for holding the
type
of timestamp. - timestampType() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- toClass(Headers) - Method in interface org.springframework.kafka.support.converter.ClassMapper
- toClass(Headers) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- ToFromStringSerde<T> - Class in org.springframework.kafka.support.serializer
-
A Serde that delegates to a
ToStringSerializer
andParseStringDeserializer
. - ToFromStringSerde(ToStringSerializer<T>, ParseStringDeserializer<T>) - Constructor for class org.springframework.kafka.support.serializer.ToFromStringSerde
-
Construct an instance with the provided properties.
- toHeaders(Headers, Map<String, Object>) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
- toHeaders(Headers, Map<String, Object>) - Method in interface org.springframework.kafka.support.KafkaHeaderMapper
-
Map from the given target message to abstracted
MessageHeaders
. - toHeaders(Headers, Map<String, Object>) - Method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper
- toJavaType(Headers) - Method in class org.springframework.kafka.support.converter.DefaultJackson2JavaTypeMapper
- toJavaType(Headers) - Method in interface org.springframework.kafka.support.converter.Jackson2JavaTypeMapper
- toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Consumer<?, ?>, Type) - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter
-
Convert a list of
ConsumerRecord
to aMessage
. - toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Consumer<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
- toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
- toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - Method in interface org.springframework.kafka.support.converter.RecordMessageConverter
-
Convert a
ConsumerRecord
to aMessage
. - toMessagingMessage(List, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
- toMessagingMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
- topic() - Method in annotation type org.springframework.kafka.annotation.TopicPartition
-
The topic to listen on.
- topic() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders
-
The header containing the topic when sending data to Kafka.
- TopicBuilder - Class in org.springframework.kafka.config
-
Builder for a
NewTopic
. - TopicPartition - Annotation Type in org.springframework.kafka.annotation
-
Used to add topic/partition information to a
KafkaListener
. - TopicPartitionOffset - Class in org.springframework.kafka.support
-
A configuration container to represent a topic name, partition number and, optionally, an offset for it.
- TopicPartitionOffset(String, int) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with no initial offset management.
- TopicPartitionOffset(String, int, Long) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with the provided initial offset with
TopicPartitionOffset.isRelativeToCurrent()
false. - TopicPartitionOffset(String, int, Long, boolean) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with the provided initial offset.
- TopicPartitionOffset(String, int, Long, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with the provided
TopicPartitionOffset.SeekPosition
. - TopicPartitionOffset(String, int, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with the provided
TopicPartitionOffset.SeekPosition
. - TopicPartitionOffset(TopicPartition, Long, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset
-
Construct an instance with the provided
TopicPartitionOffset.SeekPosition
. - TopicPartitionOffset.SeekPosition - Enum in org.springframework.kafka.support
-
Enumeration for "special" seeks.
- topicPartitions() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
The topicPartitions for this listener when using manual topic/partition assignment.
- topicPattern() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
The topic pattern for this listener.
- topics() - Method in annotation type org.springframework.kafka.annotation.KafkaListener
-
The topics for this listener.
- topics() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Topics that should be created Topics may contain property place holders, e.g.
- toString() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
- toString() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer
- toString() - Method in class org.springframework.kafka.event.ConsumerFailedToStartEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerPausedEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerResumedEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerStartedEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerStartingEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerStoppedEvent
- toString() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent
- toString() - Method in class org.springframework.kafka.event.ContainerStoppedEvent
- toString() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
- toString() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent
- toString() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- toString() - Method in class org.springframework.kafka.listener.adapter.InvocationResult
- toString() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
- toString() - Method in class org.springframework.kafka.listener.ConsumerProperties
- toString() - Method in class org.springframework.kafka.listener.ContainerProperties
- toString() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
- toString() - Method in class org.springframework.kafka.requestreply.CorrelationKey
- toString() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
- toString() - Method in class org.springframework.kafka.support.SendResult
- toString() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
- toString() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- toString() - Method in class org.springframework.kafka.test.core.BrokerAddress
- ToStringSerializer<T> - Class in org.springframework.kafka.support.serializer
-
Generic
Serializer
that relies onObject.toString()
to get serialized representation of the entity. - ToStringSerializer() - Constructor for class org.springframework.kafka.support.serializer.ToStringSerializer
- TRACE - org.springframework.kafka.KafkaException.Level
-
Trace.
- TRACE - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Trace.
- transactionCapable() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
- transactionCapable() - Method in interface org.springframework.kafka.core.ProducerFactory
-
Return true if the factory supports transactions.
- transactionManager() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate
- TransactionSupport - Class in org.springframework.kafka.support
-
Utilities for supporting transactions.
- transform(K, V) - Method in class org.springframework.kafka.streams.HeaderEnricher
- transform(K, V) - Method in class org.springframework.kafka.streams.messaging.MessagingTransformer
- trusted(String) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
- TRUSTED_PACKAGES - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property for trusted deserialization packages.
- trustedPackages(String...) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Add trusted packages to the default type mapper.
- TYPE_ID - org.springframework.kafka.support.converter.Jackson2JavaTypeMapper.TypePrecedence
- TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property to add type mappings to the type mapper: 'foo=com.Foo,bar=com.Bar'.
- TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonSerializer
-
Kafka config property to add type mappings to the type mapper: 'foo:com.Foo,bar:com.Bar'.
- typeFunction(BiFunction<byte[], Headers, JavaType>) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set a
BiFunction
that receives the data to be deserialized and the headers and returns a JavaType. - typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
- typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer
- typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Use the supplied
Jackson2JavaTypeMapper
. - typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonSerde
-
Use the supplied
Jackson2JavaTypeMapper
. - typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
-
Use the supplied
Jackson2JavaTypeMapper
. - typeResolver(JsonTypeResolver) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Set a
JsonTypeResolver
that receives the data to be deserialized and the headers and returns a JavaType.
U
- unregisterSeekCallback() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware
- unregisterSeekCallback() - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
-
Called when the listener consumer terminates allowing implementations to clean up state, such as thread locals.
- USE_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property for using type headers (default true).
V
- value() - Method in annotation type org.springframework.kafka.annotation.KafkaListeners
- value() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
- value(V) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
- VALUE_DEFAULT_TYPE - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
Kafka config property for the default value type if no header.
- VALUE_DESERIALIZER_CLASS - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Property name for the delegate value deserializer.
- VALUE_DESERIALIZER_EXCEPTION_HEADER - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Header name for deserialization exceptions.
- VALUE_FUNCTION - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
-
Supplier for a T when deserialization fails.
- VALUE_PARSER - Static variable in class org.springframework.kafka.support.serializer.ParseStringDeserializer
-
Property for the key parser method.
- VALUE_SERIALIZATION_SELECTOR - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Name of the header containing the serialization selector for values.
- VALUE_SERIALIZATION_SELECTOR_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer
-
Name of the configuration property containing the serialization selector map for values with format
selector:class,...
. - VALUE_TYPE - Static variable in class org.springframework.kafka.support.serializer.ToStringSerializer
-
Header for the type of value.
- VALUE_TYPE_METHOD - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer
-
A method name to determine the
JavaType
to deserialize the key to. - valueOf(String) - Static method in enum org.springframework.kafka.KafkaException.Level
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.listener.ContainerProperties.AckMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.listener.ContainerProperties.EOSMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.listener.ListenerType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.support.converter.Jackson2JavaTypeMapper.TypePrecedence
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.kafka.support.TopicPartitionOffset.SeekPosition
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.springframework.kafka.KafkaException.Level
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.listener.ContainerProperties.AckMode
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.listener.ContainerProperties.EOSMode
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.listener.ListenerType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.support.converter.Jackson2JavaTypeMapper.TypePrecedence
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.springframework.kafka.support.TopicPartitionOffset.SeekPosition
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- waitForAssignment(Object, int) - Static method in class org.springframework.kafka.test.utils.ContainerTestUtils
-
Wait until the container has the required number of assigned partitions.
- wantsPollResult() - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
- wantsPollResult() - Method in interface org.springframework.kafka.listener.BatchMessageListener
-
Return true if this listener wishes to receive the original
ConsumerRecords
object instead of a list ofConsumerRecord
. - WARN - org.springframework.kafka.KafkaException.Level
-
Warn.
- WARN - org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Warn.
Z
- zkConnectionTimeout() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Timeout for internal ZK client connection.
- zkConnectionTimeout(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set connection timeout for the client to the embedded Zookeeper.
- zkPort(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set an explicit port for the embedded Zookeeper.
- zkPort(int) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
- zkSessionTimeout() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Timeout for internal ZK client session.
- zkSessionTimeout(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
-
Set session timeout for the client to the embedded Zookeeper.
- zookeeperPort() - Method in annotation type org.springframework.kafka.test.context.EmbeddedKafka
-
Set the port on which the embedded Zookeeper should listen;
All Classes All Packages