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

M

manageNonBlockingFatalExceptions(List<Class<? extends Throwable>>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport

Override this method to manage non-blocking retries fatal exceptions.

MANUAL - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

Listener is responsible for acking - use a AcknowledgingMessageListener; acks will be queued and offsets will be committed when all the records returned by the previous poll have been processed by the listener.

MANUAL_IMMEDIATE - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

Listener is responsible for acking - use a AcknowledgingMessageListener; the commit will be performed immediately if the Acknowledgment is acknowledged on the calling consumer thread; otherwise, the acks will be queued and offsets will be committed when all the records returned by the previous poll have been processed by the listener; results will be indeterminate if you sometimes acknowledge on the calling thread and sometimes not.

ManualAckListenerErrorHandler - Interface in org.springframework.kafka.listener

A KafkaListenerErrorHandler that supports manual acks.

MappingJacksonParameterizedConverter - Class in org.springframework.kafka.support.converter

Subclass of MappingJackson2MessageConverter that can handle parameterized (generic) types.

MappingJacksonParameterizedConverter() - Constructor for class org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter

Construct a MappingJacksonParameterizedConverter supporting the application/json MIME type with UTF-8 character set.

MappingJacksonParameterizedConverter(MimeType...) - Constructor for class org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter

Construct a MappingJacksonParameterizedConverter supporting one or more custom MIME types.

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

matchesForInbound(String) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper

Matches header names for inbound mapping when configured as an inbound mapper.

matchHandlerMethod(Class<?>, 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

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

Configure the maximum delivery attempts (including the first).

maybeAddTo(String) - Method in class org.springframework.kafka.support.Suffixer

maybeAddTo(Collection<String>) - Method in class org.springframework.kafka.support.Suffixer

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.

messageReturnType() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

Returns the value of the messageReturnType record component.

MESSAGING_CLIENT_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags

Messaging client id.

MESSAGING_CONSUMER_GROUP - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Messaging the consumer group.

MESSAGING_CONSUMER_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags

Messaging consumer id (consumer group and client id).

MESSAGING_DESTINATION_KIND - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags

Messaging destination kind.

MESSAGING_DESTINATION_NAME - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags

Messaging destination name.

MESSAGING_OFFSET - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags

Messaging message offset.

MESSAGING_OPERATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Messaging operation.

MESSAGING_OPERATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags

Messaging operation.

MESSAGING_PARTITION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags

Messaging partition.

MESSAGING_SOURCE_KIND - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Messaging source kind.

MESSAGING_SOURCE_NAME - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Messaging source name.

MESSAGING_SYSTEM - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

Messaging system.

MESSAGING_SYSTEM - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags

Messaging system.

MessagingFunction - Interface in org.springframework.kafka.streams.messaging

A function that receives a spring-messaging Message and returns a Message.

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

Construct an instance that uses the KafkaHeaders.PARTITION to determine the target partition.

MessagingMessageConverter(Function<Message<?>, Integer>) - Constructor for class org.springframework.kafka.support.converter.MessagingMessageConverter

Construct an instance that uses the supplied partition provider function.

MessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter

An abstract MessageListener adapter providing the necessary infrastructure to extract the payload of a Message.

MessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Create an instance with the provided bean and method.

MessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - Constructor for class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Create an instance with the provided bean, method and kafka listener error handler.

MessagingMessageListenerAdapter.ReplyExpressionRoot - Record Class in org.springframework.kafka.listener.adapter

Root object for reply expression evaluation.

MessagingProcessor<Kin,Vin,Kout,Vout> - Class in org.springframework.kafka.streams.messaging

A Transformer implementation that invokes a MessagingFunction converting to/from spring-messaging Message.

MessagingProcessor(MessagingFunction, MessagingMessageConverter) - Constructor for class org.springframework.kafka.streams.messaging.MessagingProcessor

Construct an instance with the provided function and converter.

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, Function<Object, 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.

MockConsumerFactory<K,V> - Class in org.springframework.kafka.mock

Support the use of MockConsumer in tests.

MockConsumerFactory(Supplier<MockConsumer<K, V>>) - Constructor for class org.springframework.kafka.mock.MockConsumerFactory

Create an instance with the supplied consumer provider.

MockProducerFactory<K,V> - Class in org.springframework.kafka.mock

Support the use of MockProducer in tests.

MockProducerFactory(BiFunction<Boolean, String, MockProducer<K, V>>, String) - Constructor for class org.springframework.kafka.mock.MockProducerFactory

Create an instance that supports transactions, with the supplied producer provider BiFunction.

MockProducerFactory(Supplier<MockProducer<K, V>>) - Constructor for class org.springframework.kafka.mock.MockProducerFactory

Create an instance that does not support transactional producers.

MultiMethodKafkaListenerEndpoint<K,V> - Class in org.springframework.kafka.config

The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.

MultiMethodKafkaListenerEndpoint(List<Method>, Method, Object) - Constructor for class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint

Construct an instance for the provided methods, default method and bean.

MULTIPLE_TOPICS - Enum constant in enum class org.springframework.kafka.retrytopic.SameIntervalTopicReuseStrategy

Uses one separate topic per retry attempt.

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