Index

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

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 a RecordFilterStrategy.
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 a RecordFilterStrategy.
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 and TimestampedException.
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
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; default topic-partition@offset.
format(ProducerRecord<?, ?>) - Static method in class org.springframework.kafka.support.KafkaUtils
Format the ProducerRecord for logging; default ProducerRecordObject.toString().
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.
A B C D E F G H I J K L M N O P R S T U V W Z 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form