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<? extends Object>, 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.

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

MessagingTransformer<K,V,R> - Class in org.springframework.kafka.streams.messaging

Deprecated.

in favor of MessagingProcessor.

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

Deprecated.

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 interface org.springframework.kafka.core.KafkaOperations2

Deprecated.

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.

MicrometerHolder(ApplicationContext, String, String, String, Map<String, String>) - Constructor for class org.springframework.kafka.support.micrometer.MicrometerHolder

Deprecated.

in favor of MicrometerHolder(ApplicationContext, String, String, String, Function).

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>) - Constructor for class org.springframework.kafka.mock.MockConsumerFactory

Create an instance with the supplied consumer provicer.

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>) - 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.FixedDelayStrategy

Deprecated.

Uses one separate topic per retry attempt.

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