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

main(String[]) - Static method in class org.springframework.kafka.jdocs.requestreply.Application

main(String[]) - Static method in class org.springframework.kafka.jdocs.started.consumer.Application

main(String[]) - Static method in class org.springframework.kafka.jdocs.started.noboot.Sender

main(String[]) - Static method in class org.springframework.kafka.jdocs.started.producer.Application

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.

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

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

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

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

MESSAGE_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the message key when sending data to Kafka.

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

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

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

Root object for reply expression evaluation.

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

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

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

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

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

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