A B C D E F G H I K L M O P R S T V W

A

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

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

AbstractAdaptableMessageListener() - Constructor for class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener

AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V> - Class in org.springframework.kafka.config

Base KafkaListenerContainerFactory for Spring's base container implementation.

AbstractKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

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

Base model for a Kafka listener endpoint.

AbstractKafkaListenerEndpoint() - Constructor for class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

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

The base implementation for the MessageListenerContainer.

AbstractMessageListenerContainer() - Constructor for class org.springframework.kafka.listener.AbstractMessageListenerContainer

AbstractMessageListenerContainer.AckMode - Enum in org.springframework.kafka.listener

The offset commit behavior enumeration.

acknowledge() - Method in interface org.springframework.kafka.support.Acknowledgment

Invoked when the message for which the acknowledgment has been created has been processed.

AcknowledgingMessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.

Acknowledgment - Interface in org.springframework.kafka.support

Handle for acknowledging the processing of a ConsumerRecord.

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

The header for Acknowledgment.

after() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

afterPropertiesSet() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

afterPropertiesSet() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

afterSingletonsInstantiated() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

B

before() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

bounce(BrokerAddress) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

bounce(int, boolean) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

bounce(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

BrokerAddress - Class in org.springframework.kafka.test.core

Encapsulates the address of a Kafka broker.

BrokerAddress(String, int) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

BrokerAddress(String) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

BrokerAddress(BrokerEndPoint) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

C

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

Creates 1 or more KafkaMessageListenerContainers based on concurrency.

ConcurrentMessageListenerContainer(ConsumerFactory<K, V>, TopicPartition...) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Construct an instance with the supplied configuration properties and specific topics/partitions - when using this constructor, recentOffset can be specified.

ConcurrentMessageListenerContainer(ConsumerFactory<K, V>, String...) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Construct an instance with the supplied configuration properties and topics.

ConcurrentMessageListenerContainer(ConsumerFactory<K, V>, Pattern) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Construct an instance with the supplied configuration properties and topic pattern.

configureKafkaListeners(KafkaListenerEndpointRegistrar) - Method in interface org.springframework.kafka.annotation.KafkaListenerConfigurer

Callback allowing a KafkaListenerEndpointRegistry and specific KafkaListenerEndpoint instances to be registered against the given KafkaListenerEndpointRegistrar.

configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Create a HandlerAdapter for this listener adapter.

configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - Method in class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint

ConsumerFactory<K,V> - Interface in org.springframework.kafka.core

The strategy to produce a Consumer instance(s).

consumerProps(String, String, KafkaEmbedded) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

Set up test properties for an <Integer, String> consumer.

consumerProps(String, String, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

ConsumerRecordKeyCondition(K) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition

ConsumerRecordKeyMatcher(K) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher

ConsumerRecordPartitionCondition(int) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition

ConsumerRecordPartitionMatcher(int) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher

ConsumerRecordValueCondition(V) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition

ConsumerRecordValueMatcher(V) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher

convertAndSend(V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with no key or partition.

convertAndSend(K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with the provided key and no partition.

convertAndSend(int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with the provided key and partition.

convertAndSend(String, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with no key or partition.

convertAndSend(String, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with the provided key and no partition.

convertAndSend(String, int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with the provided key and partition.

convertAndSend(V) - Method in class org.springframework.kafka.core.KafkaTemplate

convertAndSend(K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

convertAndSend(int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

convertAndSend(String, V) - Method in class org.springframework.kafka.core.KafkaTemplate

convertAndSend(String, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

convertAndSend(String, int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

createConsumer() - Method in interface org.springframework.kafka.core.ConsumerFactory

createConsumer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Create an empty container instance.

createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory

createListenerContainer(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

createListenerContainer(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.config.KafkaListenerContainerFactory

Create a MessageListenerContainer for the given KafkaListenerEndpoint.

createListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Create and start a new MessageListenerContainer using the specified factory.

createMessageListener(MessageListenerContainer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Create a MessageListener that is able to serve this endpoint for the specified container.

createMessageListener(MessageListenerContainer) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

createMessageListener(MessageListenerContainer) - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint

createMessageListenerInstance() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Create an empty MessagingMessageListenerAdapter instance.

createProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

createProducer() - Method in interface org.springframework.kafka.core.ProducerFactory

D

DEFAULT_PORT - Static variable in class org.springframework.kafka.test.core.BrokerAddress

DefaultKafkaConsumerFactory<K,V> - Class in org.springframework.kafka.core

The ConsumerFactory implementation to produce a new Consumer instance for provided Map configs on each DefaultKafkaConsumerFactory.createConsumer() invocation.

DefaultKafkaConsumerFactory(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory

defaultKafkaListenerEndpointRegistry() - Method in class org.springframework.kafka.annotation.KafkaBootstrapConfiguration

DefaultKafkaProducerFactory<K,V> - Class in org.springframework.kafka.core

The ProducerFactory implementation for the singleton shared Producer instance.

DefaultKafkaProducerFactory(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaProducerFactory

DelegatingInvocableHandler - Class in org.springframework.kafka.listener.adapter

Delegates to an InvocableHandlerMethod based on the message payload type.

DelegatingInvocableHandler(List<InvocableHandlerMethod>, Object) - Constructor for class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

Construct an instance with the supplied handlers for the bean.

describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher

describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher

describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher

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

destroy() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

doSend(ProducerRecord<K, V>) - Method in class org.springframework.kafka.core.KafkaTemplate

Send the producer record.

doStart() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

doStart() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

doStart() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

doStop() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

doStop() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

doStop() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

E

EnableKafka - Annotation Type in org.springframework.kafka.annotation

Enable Kafka listener annotated endpoints that are created under the covers by a AbstractListenerContainerFactory.

equals(Object) - Method in class org.springframework.kafka.test.core.BrokerAddress

ErrorHandler - Interface in org.springframework.kafka.listener

Handles errors thrown during the execution of a MessageListener.

extractAndConvertValue(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

Subclasses can convert the value; by default, it's returned as provided by Kafka.

extractMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener

Extract the message body from the given Kafka message.

F

findHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

flush() - Method in interface org.springframework.kafka.core.KafkaOperations

Flush the producer.

flush() - Method in class org.springframework.kafka.core.KafkaTemplate

fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress

G

getAckCount() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Return the count.

getAckMode() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Return the AbstractMessageListenerContainer.AckMode.

getAckTime() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Return the ack time.

getAssignedPartitions() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

Return the TopicPartitions currently assigned to this container, either explicitly or by Kafka; may be null if not assigned yet.

getBean() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

getBean() - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

Return the bean for this handler.

getBean() - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter

getBeanExpressionContext() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

getBeanFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

getBeanName() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

getBrokerAddress(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getBrokerAddresses() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getBrokerAddresses() - Method in interface org.springframework.kafka.test.rule.KafkaRule

getBrokersAsString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getBrokersAsString() - Method in interface org.springframework.kafka.test.rule.KafkaRule

getConcurrency() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

getConsumerFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

getContainers() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Return the list of KafkaMessageListenerContainers created by this container.

getDefaultTopic() - Method in class org.springframework.kafka.core.KafkaTemplate

The default topic for send methods where a topic is not providing.

getEndpointDescription() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Return a description for this endpoint.

getEndpointDescription() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

getEndpointDescription() - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint

getEndpointRegistry() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Return the KafkaListenerEndpointRegistry instance for this registrar, may be null.

getErrorHandler() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

getGroup() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

getGroup() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Return the group of this endpoint or null if not in a group.

getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

Determine the InvocableHandlerMethod for the provided type.

getHost() - Method in class org.springframework.kafka.test.core.BrokerAddress

getId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

getId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Return the id of this endpoint.

getKafkaServer(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getKafkaServers() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getKafkaServers() - Method in interface org.springframework.kafka.test.rule.KafkaRule

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

Return the MessageListenerContainer with the specified id or null if no such container exists.

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

Return the ids of the managed MessageListenerContainer instance(s).

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

Return the managed MessageListenerContainer instance(s).

getMessageConverter() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Return the MessagingMessageConverter for this listener, being able to convert Message.

getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Return the custom MessageHandlerMethodFactory to use, if any.

getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Return the MessageHandlerMethodFactory.

getMessageListener() - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint

Return the MessageListener to invoke when a message matching the endpoint is received.

getMessageListener() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

getMethod() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

getMethodAsString(Object) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter

getMethodNameFor(Object) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

Return a string representation of the method that will be invoked for this payload.

getOrder() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

getPartitionsPerTopic() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getPartitionsPerTopic() - Method in interface org.springframework.kafka.test.rule.KafkaRule

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

getPhase() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

getPollTimeout() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Return the poll timeout.

getPort() - Method in class org.springframework.kafka.test.core.BrokerAddress

getResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

getTaskExecutor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

getTopicPartitions() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Return the topicPartitions for this endpoint.

getTopicPartitions() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Return the topicPartitions for this endpoint.

getTopicPattern() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Return the topicPattern for this endpoint.

getTopicPattern() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Return the topicPattern for this endpoint.

getTopics() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Return the topics for this endpoint.

getTopics() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Return the topics for this endpoint.

getZkClient() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getZkClient() - Method in interface org.springframework.kafka.test.rule.KafkaRule

getZookeeper() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getZookeeperConnectionString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

getZookeeperConnectionString() - Method in interface org.springframework.kafka.test.rule.KafkaRule

H

handle(Exception, ConsumerRecord<?, ?>) - Method in interface org.springframework.kafka.listener.ErrorHandler

handle(Exception, ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.listener.LoggingErrorHandler

handleListenerException(Throwable) - Method in class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener

Handle the given exception that arose during listener execution.

HandlerAdapter - Class in org.springframework.kafka.listener.adapter

A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.

HandlerAdapter(InvocableHandlerMethod) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter

HandlerAdapter(DelegatingInvocableHandler) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter

hashCode() - Method in class org.springframework.kafka.test.core.BrokerAddress

hasKey(K) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

hasPartition(int) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

hasValue(V) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

I

initializeContainer(C) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Further initialize the specified container.

initializeContainer(ConcurrentMessageListenerContainer<K, V>) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory

invoke(Message<?>, Object...) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

Invoke the method with the given message.

invoke(Message<?>, Object...) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter

isAutoCommit() - Method in interface org.springframework.kafka.core.ConsumerFactory

isAutoCommit() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory

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

isAutoStartup() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

isEmbedded() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

isEmbedded() - Method in interface org.springframework.kafka.test.rule.KafkaRule

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

isRunning() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

isRunning() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

K

KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils

The bean name of the internally managed Kafka listener annotation processor.

KAFKA_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils

The bean name of the internally managed Kafka listener endpoint registry.

KafkaBootstrapConfiguration - Class in org.springframework.kafka.annotation

@Configuration class that registers a KafkaListenerAnnotationBeanPostProcessor bean capable of processing Spring's @KafkaListener annotation.

KafkaBootstrapConfiguration() - Constructor for class org.springframework.kafka.annotation.KafkaBootstrapConfiguration

KafkaConditions - Class in org.springframework.kafka.test.assertj

AssertJ custom Conditions.

KafkaConditions.ConsumerRecordKeyCondition<K> - Class in org.springframework.kafka.test.assertj

KafkaConditions.ConsumerRecordPartitionCondition - Class in org.springframework.kafka.test.assertj

KafkaConditions.ConsumerRecordValueCondition<V> - Class in org.springframework.kafka.test.assertj

KafkaEmbedded - Class in org.springframework.kafka.test.rule

The KafkaRule implementation for the embedded Kafka Broker and Zookeeper.

KafkaEmbedded(int) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded

KafkaEmbedded(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded

Create embedded Kafka brokers.

KafkaEmbedded(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded

Create embedded Kafka brokers.

KafkaException - Exception in org.springframework.kafka.core

The Spring Kafka specific NestedRuntimeException implementation.

KafkaException(String) - Constructor for exception org.springframework.kafka.core.KafkaException

KafkaException(String, Throwable) - Constructor for exception org.springframework.kafka.core.KafkaException

KafkaHandler - Annotation Type in org.springframework.kafka.annotation

Annotation that marks a method to be the target of a Kafka message listener within a class that is annotated with KafkaListener.

KafkaHeaders - Class in org.springframework.kafka.support

The Kafka specific message headers constants.

KafkaHeaders() - Constructor for class org.springframework.kafka.support.KafkaHeaders

KafkaListener - Annotation Type in org.springframework.kafka.annotation

Annotation that marks a method to be the target of a Kafka message listener on the specified topics.

KafkaListenerAnnotationBeanPostProcessor<K,V> - Class in org.springframework.kafka.annotation

Bean post-processor that registers methods annotated with KafkaListener to be invoked by a Kafka message listener container created under the covers by a KafkaListenerContainerFactory according to the parameters of the annotation.

KafkaListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

kafkaListenerAnnotationProcessor() - Method in class org.springframework.kafka.annotation.KafkaBootstrapConfiguration

KafkaListenerConfigurer - Interface in org.springframework.kafka.annotation

Optional interface to be implemented by Spring managed bean willing to customize how Kafka listener endpoints are configured.

KafkaListenerConfigUtils - Class in org.springframework.kafka.config

Configuration constants for internal sharing across subpackages.

KafkaListenerConfigUtils() - Constructor for class org.springframework.kafka.config.KafkaListenerConfigUtils

KafkaListenerContainerFactory<C extends MessageListenerContainer> - Interface in org.springframework.kafka.config

Factory of MessageListenerContainer based on a KafkaListenerEndpoint definition.

KafkaListenerEndpoint - Interface in org.springframework.kafka.config

Model for a Kafka listener endpoint.

KafkaListenerEndpointRegistrar - Class in org.springframework.kafka.config

Helper bean for registering KafkaListenerEndpoint with a KafkaListenerEndpointRegistry.

KafkaListenerEndpointRegistrar() - Constructor for class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

KafkaListenerEndpointRegistry - Class in org.springframework.kafka.config

Creates the necessary MessageListenerContainer instances for the registered endpoints.

KafkaListenerEndpointRegistry() - Constructor for class org.springframework.kafka.config.KafkaListenerEndpointRegistry

KafkaListeners - Annotation Type in org.springframework.kafka.annotation

Container annotation that aggregates several KafkaListener annotations.

KafkaMatchers - Class in org.springframework.kafka.test.hamcrest

Hamcrest Matchers utilities.

KafkaMatchers.ConsumerRecordKeyMatcher<K> - Class in org.springframework.kafka.test.hamcrest

KafkaMatchers.ConsumerRecordPartitionMatcher - Class in org.springframework.kafka.test.hamcrest

KafkaMatchers.ConsumerRecordValueMatcher<V> - Class in org.springframework.kafka.test.hamcrest

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

Single-threaded Message listener container using the Java Consumer supporting auto-partition assignment or user-configured assignment.

KafkaMessageListenerContainer(ConsumerFactory<K, V>, TopicPartition...) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer

Construct an instance with the supplied configuration properties and specific topics/partitions - when using this constructor, recentOffset can be specified.

KafkaMessageListenerContainer(ConsumerFactory<K, V>, String...) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer

Construct an instance with the supplied configuration properties and topics.

KafkaMessageListenerContainer(ConsumerFactory<K, V>, Pattern) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer

Construct an instance with the supplied configuration properties and topic pattern.

KafkaOperations<K,V> - Interface in org.springframework.kafka.core

The basic Kafka operations contract.

KafkaRule - Interface in org.springframework.kafka.test.rule

Common functionality for the Kafka JUnit rules

KafkaTemplate<K,V> - Class in org.springframework.kafka.core

A template for executing high-level operations.

KafkaTemplate(ProducerFactory<K, V>) - Constructor for class org.springframework.kafka.core.KafkaTemplate

Create an instance using the supplied producer factory.

KafkaTestUtils - Class in org.springframework.kafka.test.utils

Kafka testing utilities.

key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

L

ListenerExecutionFailedException - Exception in org.springframework.kafka.listener

The listener specific KafkaException extension.

ListenerExecutionFailedException(String) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

logger - Variable in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

logger - Variable in class org.springframework.kafka.core.KafkaTemplate

logger - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

logger - Variable in class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener

LoggingErrorHandler - Class in org.springframework.kafka.listener

The ErrorHandler implementation for logging purpose.

LoggingErrorHandler() - Constructor for class org.springframework.kafka.listener.LoggingErrorHandler

LoggingProducerListener<K,V> - Class in org.springframework.kafka.support

The ProducerListener that logs exceptions thrown when sending messages.

LoggingProducerListener() - Constructor for class org.springframework.kafka.support.LoggingProducerListener

M

matches(ConsumerRecord<K, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition

matches(ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition

matches(ConsumerRecord<?, V>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition

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

matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler

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

The header for message key.

MessageConverter<K,V> - Interface in org.springframework.kafka.support.converter

The Kafka specific Message converter strategy.

MessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling incoming Kafka messages.

MessageListenerContainer - Interface in org.springframework.kafka.listener

Internal abstraction used by the framework representing a message listener container.

MessagingMessageConverter<K,V> - Class in org.springframework.kafka.support.converter

The Messaging specific MessageConverter implementation.

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

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

A MessageListener adapter that invokes a configurable HandlerAdapter.

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

METADATA_PROPAGATION_TIMEOUT - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded

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

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

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

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

O

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

The header for partition offset.

onCompletion(RecordMetadata, Exception) - Method in class org.springframework.kafka.support.ProducerListenerInvokingCallback

onError(String, Integer, K, V, Exception) - Method in class org.springframework.kafka.support.LoggingProducerListener

onError(String, Integer, K, V, Exception) - Method in interface org.springframework.kafka.support.ProducerListener

Invoked after an attempt to send a message has failed.

onError(String, Integer, K, V, Exception) - Method in class org.springframework.kafka.support.ProducerListenerAdapter

onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in interface org.springframework.kafka.listener.AcknowledgingMessageListener

Executes when a Kafka message is received.

onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener

Kafka MessageListener entry point.

onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

onMessage(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.MessageListener

Executes when a ConsumerRecord is received.

onSuccess(String, Integer, K, V, RecordMetadata) - Method in interface org.springframework.kafka.support.ProducerListener

Invoked after the successful send of a message (that is, after it has been acknowledged by the broker).

onSuccess(String, Integer, K, V, RecordMetadata) - Method in class org.springframework.kafka.support.ProducerListenerAdapter

org.springframework.kafka.annotation - package org.springframework.kafka.annotation

Package for kafka annotations

org.springframework.kafka.config - package org.springframework.kafka.config

Package for kafka configuration

org.springframework.kafka.core - package org.springframework.kafka.core

Package for kafka core components

org.springframework.kafka.listener - package org.springframework.kafka.listener

Package for kafka listeners

org.springframework.kafka.listener.adapter - package org.springframework.kafka.listener.adapter

Provides classes for adapting listeners.

org.springframework.kafka.support - package org.springframework.kafka.support

Package for kafka support

org.springframework.kafka.support.converter - package org.springframework.kafka.support.converter

Package for kafka converters

org.springframework.kafka.test.assertj - package org.springframework.kafka.test.assertj

org.springframework.kafka.test.core - package org.springframework.kafka.test.core

org.springframework.kafka.test.hamcrest - package org.springframework.kafka.test.hamcrest

org.springframework.kafka.test.rule - package org.springframework.kafka.test.rule

org.springframework.kafka.test.utils - package org.springframework.kafka.test.utils

P

partition(int) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

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

The header for topic partition.

postProcessAfterInitialization(Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

processKafkaListener(KafkaListener, Method, Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

processListener(MethodKafkaListenerEndpoint<?, ?>, KafkaListener, Object, Object, String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

ProducerFactory<K,V> - Interface in org.springframework.kafka.core

The strategy to produce a Producer instance(s).

ProducerListener<K,V> - Interface in org.springframework.kafka.support

Listener for handling outbound Kafka messages.

ProducerListenerAdapter<K,V> - Class in org.springframework.kafka.support

No-op implementation of ProducerListener, to be used as base class for other implementations.

ProducerListenerAdapter() - Constructor for class org.springframework.kafka.support.ProducerListenerAdapter

ProducerListenerInvokingCallback<K,V> - Class in org.springframework.kafka.support

Adapts the Callback interface of the Producer to a ProducerListener.

ProducerListenerInvokingCallback(String, Integer, K, V, ProducerListener<K, V>) - Constructor for class org.springframework.kafka.support.ProducerListenerInvokingCallback

producerProps(KafkaEmbedded) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

Set up test properties for an <Integer, String> producer.

R

registerAllEndpoints() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

registerEndpoint(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Register a new KafkaListenerEndpoint alongside the KafkaListenerContainerFactory to use to create the underlying container.

registerEndpoint(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Register a new KafkaListenerEndpoint using the default KafkaListenerContainerFactory to create the underlying container.

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Create a message listener container for the given KafkaListenerEndpoint.

registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>, boolean) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

Create a message listener container for the given KafkaListenerEndpoint.

restart(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

S

senderProps(String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

setAckCount(Integer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify an ackCount to use.

setAckCount(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Set the number of outstanding record count after which offsets should be committed when AbstractMessageListenerContainer.AckMode.COUNT or AbstractMessageListenerContainer.AckMode.COUNT_TIME is being used.

setAckMode(AbstractMessageListenerContainer.AckMode) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify an AbstractMessageListenerContainer.AckMode to use.

setAckMode(AbstractMessageListenerContainer.AckMode) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

The ack mode to use when auto ack (in the configuration properties) is false.

setAckTime(long) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Set the time (ms) after which outstanding offsets should be committed when AbstractMessageListenerContainer.AckMode.TIME or AbstractMessageListenerContainer.AckMode.COUNT_TIME is being used.

setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

setAutoStartup(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify an autoStartup boolean flag.

setAutoStartup(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setBean(Object) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Set the object instance that should manage this endpoint.

setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

Making a BeanFactory available is optional; if not set, KafkaListenerConfigurer beans won't get autodetected and an endpoint registry has to be explicitly configured.

setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

A BeanFactory only needs to be available in conjunction with KafkaListenerEndpointRegistrar.setContainerFactoryBeanName(java.lang.String).

setBeanName(String) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setConcurrency(Integer) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory

Specify the container concurrency.

setConcurrency(int) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

The maximum number of concurrent KafkaMessageListenerContainers running.

setConsumerFactory(ConsumerFactory<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify a ConsumerFactory to use.

setContainerFactory(KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Set the KafkaListenerContainerFactory to use in case a KafkaListenerEndpoint is registered with a null container factory.

setContainerFactoryBeanName(String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

Set the name of the KafkaListenerContainerFactory to use by default.

setContainerFactoryBeanName(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Set the bean name of the KafkaListenerContainerFactory to use in case a KafkaListenerEndpoint is registered with a null container factory.

setDefaultTopic(String) - Method in class org.springframework.kafka.core.KafkaTemplate

Set the default topic for send methods where a topic is not providing.

setEndpointRegistry(KafkaListenerEndpointRegistry) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

Set the KafkaListenerEndpointRegistry that will hold the created endpoint and manage the lifecycle of the related listener container.

setEndpointRegistry(KafkaListenerEndpointRegistry) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Set the KafkaListenerEndpointRegistry instance to use.

setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify an ErrorHandler to use.

setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setGenerateMessageId(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

Generate Message ids for produced messages.

setGenerateTimestamp(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

Generate timestamp for produced messages.

setGroup(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Set the group for the corresponding listener container.

setHandlerMethod(HandlerAdapter) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Set the HandlerAdapter to use to invoke the method processing an incoming ConsumerRecord.

setId(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

setIncludeContents(boolean) - Method in class org.springframework.kafka.support.LoggingProducerListener

Whether the log message should include the contents (key and payload).

setMaxContentLogged(int) - Method in class org.springframework.kafka.support.LoggingProducerListener

The maximum amount of data to be logged for either key or password.

setMessageConverter(MessageConverter<K, V>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Set the MessageConverter.

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

Set the MessageHandlerMethodFactory to use to configure the message listener responsible to serve an endpoint detected by this processor.

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar

Set the MessageHandlerMethodFactory to use to configure the message listener responsible to serve an endpoint detected by this processor.

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.

setMessageListener(MessageListener<K, V>) - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint

Set the MessageListener to invoke when a message matching the endpoint is received.

setMessageListener(Object) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

Set the message listener; must be a MessageListener or AcknowledgingMessageListener.

setMethod(Method) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint

Set the method to invoke to process a message managed by this endpoint.

setPhase(int) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify a phase to use.

setPhase(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setPollTimeout(Long) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify a pollTimeout to use.

setPollTimeout(long) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

The max time to block in the consumer waiting for records.

setProducerListener(ProducerListener<K, V>) - Method in class org.springframework.kafka.core.KafkaTemplate

Set a ProducerListener which will be invoked when Kafka acknowledges a send operation.

setRecentOffset(Long) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory

Specify the offset lag from the end of commit.

setRecentOffset(long) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

Set the offset to this number of records back from the latest when starting.

setRecentOffset(long) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

Set the offset to this number of records back from the latest when starting.

setRunning(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setTaskExecutor(Executor) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

Specify an Executor to use.

setTaskExecutor(Executor) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setTopicPartitions(TopicPartition...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Set the topics to use.

setTopicPattern(Pattern) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Set the topic pattern to use.

setTopics(String...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

Set the topics to use.

setupListenerContainer(MessageListenerContainer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

setupListenerContainer(MessageListenerContainer) - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint

Setup the specified message listener container with the model defined by this endpoint.

setupMessageListener(Object) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

setupMessageListener(Object) - Method in interface org.springframework.kafka.listener.MessageListenerContainer

Setup the message listener to use.

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

A KafkaListenerContainerFactory implementation to build a regular ConcurrentMessageListenerContainer.

SimpleKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory

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

A KafkaListenerEndpoint simply providing the MessageListener to invoke to process an incoming message for this endpoint.

SimpleKafkaListenerEndpoint() - Constructor for class org.springframework.kafka.config.SimpleKafkaListenerEndpoint

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

start() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

start() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

startZookeeper() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

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

stop(Runnable) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

stop() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

stop() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

stop(Runnable) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer

syncConvertAndSend(V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with no key or partition; wait for result.

syncConvertAndSend(K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with the provided key and no partition; wait for result.

syncConvertAndSend(int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the default topic with the provided key and partition.

syncConvertAndSend(String, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with no key or partition.; wait for result.

syncConvertAndSend(String, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with the provided key and no partition; wait for result.

syncConvertAndSend(String, int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations

Send the data to the provided topic with the provided key and partition; wait for result.

syncConvertAndSend(V) - Method in class org.springframework.kafka.core.KafkaTemplate

syncConvertAndSend(K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

syncConvertAndSend(int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

syncConvertAndSend(String, V) - Method in class org.springframework.kafka.core.KafkaTemplate

syncConvertAndSend(String, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

syncConvertAndSend(String, int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate

T

toMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in interface org.springframework.kafka.support.converter.MessageConverter

toMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

toMessagingMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

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

The header for topic.

TopicPartition - Annotation Type in org.springframework.kafka.annotation

Used to add topic/partition information to a KafkaListener.

toString() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

toString() - Method in class org.springframework.kafka.test.core.BrokerAddress

V

value(V) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

valueOf(String) - Static method in enum org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.kafka.listener.AbstractMessageListenerContainer.AckMode

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitUntilSynced(String, int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

A B C D E F G H I K L M O P R S T V W