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, Class<?>, Object) - Method in class org.springframework.kafka.annotation.RetryTopicConfigurationProvider

Find retry topic configuration.

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.

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.RoutingKafkaTemplate

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