Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
F
- FAIL_ON_ERROR - Enum constant in enum class org.springframework.kafka.retrytopic.DltStrategy
-
Fail if DLT processing throws an error.
- FailedBatchProcessor - Class in org.springframework.kafka.listener
-
Subclass of
FailedRecordProcessor
that can process (and recover) a batch. - FailedBatchProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler, CommonErrorHandler) - Constructor for class org.springframework.kafka.listener.FailedBatchProcessor
-
Construct an instance with the provided properties.
- FailedBatchProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, CommonErrorHandler) - Constructor for class org.springframework.kafka.listener.FailedBatchProcessor
-
Construct an instance with the provided properties.
- failedDelivery(ConsumerRecord<?, ?>, Exception, int) - Method in interface org.springframework.kafka.listener.RetryListener
-
Called after a delivery failed for a record.
- failedDelivery(ConsumerRecords<?, ?>, Exception, int) - Method in interface org.springframework.kafka.listener.RetryListener
-
Called after a delivery failed for batch records.
- 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
- FailedRecordProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler) - Constructor for class org.springframework.kafka.listener.FailedRecordProcessor
- failure(Object, String) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Record failure.
- failure(Object, String, Object) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder
-
Record failure.
- failure(ConsumerRecord<K, V>, Exception, Consumer<K, V>) - Method in class org.springframework.kafka.listener.CompositeRecordInterceptor
- failure(ConsumerRecord<K, V>, Exception, Consumer<K, V>) - Method in interface org.springframework.kafka.listener.RecordInterceptor
-
Called after the listener throws an exception.
- failure(ConsumerRecords<K, V>, Exception, Consumer<K, V>) - Method in interface org.springframework.kafka.listener.BatchInterceptor
-
Called after the listener throws an exception.
- failure(ConsumerRecords<K, V>, Exception, Consumer<K, V>) - Method in class org.springframework.kafka.listener.CompositeBatchInterceptor
- FATAL - Enum constant in enum class org.springframework.kafka.KafkaException.Level
-
Fatal.
- FATAL - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level
-
Fatal.
- FENCED - Enum constant in enum class org.springframework.kafka.event.ConsumerStoppedEvent.Reason
-
The transactional producer was fenced and the container
stopContainerWhenFenced
property is true. - filter() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
-
Set an
RecordFilterStrategy
bean name to override the strategy configured on the container factory. - 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.
- filterBatch(List<ConsumerRecord<K, V>>) - Method in interface org.springframework.kafka.listener.adapter.RecordFilterStrategy
-
Filter an entire batch of records; to filter all records, return an empty list, not null.
- 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.
- findDelegate(String) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization
-
Determine the delegate for the topic.
- findDelegate(T, Map<Class<?>, Serializer<?>>) - Method in class org.springframework.kafka.support.serializer.DelegatingByTypeSerializer
-
Determine the serializer for the data type.
- findHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
- findRetryConfigurationFor(String[], Method, Object) - Method in class org.springframework.kafka.annotation.RetryTopicConfigurationProvider
- findRootCause(Exception) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils
-
Find the root cause, ignoring any
ListenerExecutionFailedException
andTimestampedException
. - fixedBackOff(int) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
-
Configure a
FixedBackOffPolicy
. - fixedBackOff(long) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
-
Configure a
FixedBackOffPolicy
. - FixedDelayStrategy - Enum Class in org.springframework.kafka.retrytopic
-
Deprecated.
- fixedDelayTopicStrategy() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic
-
Deprecated.in favor of
RetryableTopic.sameIntervalTopicReuseStrategy()
. - 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 interface org.springframework.kafka.core.KafkaOperations2
-
Deprecated.Flush the producer.
- flush() - Method in class org.springframework.kafka.core.KafkaTemplate
-
Flush the producer.
- flush() - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
- forContainerFactoryConfigurer() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
- forContainerFactoryResolver() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
- forInboundOnlyWithMatchers(ObjectMapper, String...) - Static method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Create an instance for inbound mapping only with pattern matching.
- forInboundOnlyWithMatchers(String...) - Static method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper
-
Create an instance for inbound mapping only with pattern matching.
- forInboundOnlyWithMatchers(String...) - Static method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper
-
Create an instance for inbound mapping only with pattern matching.
- forKafkaTopicAutoCreation() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
- 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.
- format(ConsumerRecord<?, ?>) - Static method in class org.springframework.kafka.support.KafkaUtils
-
Format the
ConsumerRecord
for logging; defaulttopic-partition@offset
. - format(ProducerRecord<?, ?>) - Static method in class org.springframework.kafka.support.KafkaUtils
- fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress
- fromClass(Class<?>, Headers) - Method in interface org.springframework.kafka.support.mapping.ClassMapper
- fromClass(Class<?>, Headers) - Method in class org.springframework.kafka.support.mapping.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 headers. - fromHeaders(MessageHeaders, Headers) - Method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper
- fromJavaType(JavaType, Headers) - Method in class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper
- fromJavaType(JavaType, Headers) - Method in interface org.springframework.kafka.support.mapping.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.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
SameIntervalTopicReuseStrategy
.