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

U

unbindClient(String, C) - Method in class org.springframework.kafka.core.KafkaMetricsSupport

Unbind a io.micrometer.core.instrument.binder.kafka.KafkaMetrics for the provided Kafka client.

uniformRandomBackoff(long, long) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure a UniformRandomBackOffPolicy.

unrecoverableBackOff(BackOff, ThreadLocal<BackOffExecution>, ThreadLocal<Long>, MessageListenerContainer) - Static method in class org.springframework.kafka.listener.ListenerUtils

Deprecated, for removal: This API element is subject to removal in a future version.

in favor of ListenerUtils.unrecoverableBackOff(BackOff, Map, Map, MessageListenerContainer).

unrecoverableBackOff(BackOff, Map<Thread, BackOffExecution>, Map<Thread, Long>, MessageListenerContainer) - Static method in class org.springframework.kafka.listener.ListenerUtils

Sleep according to the BackOff; when the BackOffExecution returns BackOffExecution.STOP sleep for the previous backOff.

unregisterListenerContainer(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Unregister the listener container with the provided id.

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.

unwrapIfNeeded(Exception) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

Remove a TimestampedException, if present.

updateConfigs(Map<String, Object>) - Method in interface org.springframework.kafka.core.ConsumerFactory

Update the consumer configuration map; useful for situations such as credential rotation.

updateConfigs(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

updateConfigs(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

updateConfigs(Map<String, Object>) - Method in interface org.springframework.kafka.core.ProducerFactory

Update the producer configuration map; useful for situations such as credential rotation.

USE_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

Kafka config property for using type headers (default true).

usedForExceptions() - Method in class org.springframework.kafka.retrytopic.DestinationTopic.Properties

usedForExceptions() - Method in class org.springframework.kafka.retrytopic.DestinationTopic

useSingleTopicForSameIntervals() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the use of a single retry topic for the attempts that have the same backoff interval (as long as these attempts are in the end of the chain).

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