Index (Spring Kafka 1.0.6.RELEASE API)

A B C D E F G H I J 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
AbstractFilteringMessageListener<K,V> - Class in org.springframework.kafka.listener.adapter: An abstract message listener adapter that implements record filter logic via a RecordFilterStrategy.
AbstractFilteringMessageListener(RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener
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(ContainerProperties) - Constructor for class org.springframework.kafka.listener.AbstractMessageListenerContainer
AbstractMessageListenerContainer.AckMode - Enum in org.springframework.kafka.listener: The offset commit behavior enumeration.
AbstractRetryingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: Base class for retrying message listener adapters.
AbstractRetryingMessageListenerAdapter(RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter: Construct an instance with the supplied retry template.
AbstractRetryingMessageListenerAdapter(RetryTemplate, RecoveryCallback<Void>) - Constructor for class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter: Construct an instance with the supplied template and callback.
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

ClientIdSuffixAware<K,V> - Interface in org.springframework.kafka.core: Deprecated.
- in 2.0, this method will move to ConsumerFactory.
close() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
close() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
ConcurrentKafkaListenerContainerFactory<K,V> - Class in org.springframework.kafka.config: A KafkaListenerContainerFactory implementation to build a ConcurrentMessageListenerContainer.
ConcurrentKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
ConcurrentMessageListenerContainer<K,V> - Class in org.springframework.kafka.listener: Creates 1 or more KafkaMessageListenerContainers based on concurrency.
ConcurrentMessageListenerContainer(ConsumerFactory<K, V>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.ConcurrentMessageListenerContainer: Construct an instance with the supplied configuration properties.
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
configure(Map<String, ?>, boolean) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
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
consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded: Subscribe a consumer to all the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded: Subscribe a consumer to one of the embedded topics.
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: Set up test properties for an <Integer, String> consumer.
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
ContainerProperties - Class in org.springframework.kafka.listener.config: Contains runtime properties for a listener container.
ContainerProperties(String...) - Constructor for class org.springframework.kafka.listener.config.ContainerProperties
ContainerProperties(Pattern) - Constructor for class org.springframework.kafka.listener.config.ContainerProperties
ContainerProperties(TopicPartitionInitialOffset...) - Constructor for class org.springframework.kafka.listener.config.ContainerProperties
ContainerTestUtils - Class in org.springframework.kafka.test.utils: Utilities for testing listener containers.
ConversionException - Exception in org.springframework.kafka.support.converter: Exception for conversions.
ConversionException(String, Throwable) - Constructor for exception org.springframework.kafka.support.converter.ConversionException
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter: Subclasses can convert the payload; by default, it's sent unchanged to Kafka.
convertPayload(Message<?>) - Method in class org.springframework.kafka.support.converter.StringJsonMessageConverter
createConsumer(String) - Method in interface org.springframework.kafka.core.ClientIdSuffixAware: Deprecated.

Create a consumer, appending the suffix to the client.id property, if present.
createConsumer() - Method in interface org.springframework.kafka.core.ConsumerFactory
createConsumer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
createConsumer(String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
createConsumerRebalanceListener() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Return default implementation of ConsumerRebalanceListener instance.
createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Create an empty container instance.
createContainerInstance(KafkaListenerEndpoint) - Method in class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
createKafkaConsumer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
createKafkaConsumer(String) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
createKafkaConsumer(Map<String, Object>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
createKafkaProducer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
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, MessageConverter) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Create a MessageListener that is able to serve this endpoint for the specified container.
createMessageListener(MessageListenerContainer, MessageConverter) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
createMessageListener(MessageListenerContainer, MessageConverter) - 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_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor: The bean name of the default KafkaListenerContainerFactory.
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 and optional Deserializer keyDeserializer, valueDeserializer implementations on each DefaultKafkaConsumerFactory.createConsumer() invocation.
DefaultKafkaConsumerFactory(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory
DefaultKafkaConsumerFactory(Map<String, Object>, Deserializer<K>, Deserializer<V>) - 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
DefaultKafkaProducerFactory(Map<String, Object>, Serializer<K>, Serializer<V>) - 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
deserialize(String, byte[]) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
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(Runnable) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
doStop(Runnable) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
doStop(Runnable) - 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.support.TopicPartitionInitialOffset
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<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter: Subclasses can convert the value; by default, it's returned as provided by Kafka.
extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.StringJsonMessageConverter
extractMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.AbstractAdaptableMessageListener: Extract the message body from the given Kafka message.

F

filter(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener
filter(ConsumerRecord<K, V>) - Method in interface org.springframework.kafka.listener.adapter.RecordFilterStrategy: Return true if the record should be discarded.
FilteringAcknowledgingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: A AcknowledgingMessageListener adapter that implements filter logic via a RecordFilterStrategy.
FilteringAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - Constructor for class org.springframework.kafka.listener.adapter.FilteringAcknowledgingMessageListenerAdapter: Create an instance with the supplied strategy and delegate listener.
FilteringMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: A MessageListener adapter that implements filter logic via a RecordFilterStrategy.
FilteringMessageListenerAdapter(MessageListener<K, V>, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter: Create an instance with the supplied strategy and delegate listener.
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
fromMessage(Message<?>, String) - Method in interface org.springframework.kafka.support.converter.MessageConverter: Convert a message to a producer record.
fromMessage(Message<?>, String) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

G

getAckCount() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getAckMode() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getAckTime() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getApplicationEventPublisher() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
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
getCommitCallback() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getConcurrency() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
getConfigurationProperties() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Return an unmodifiable reference to the configuration map for this factory.
getConsumerFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
getConsumerRebalanceListener() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getConsumerTaskExecutor() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getContainerProperties() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Obtain the properties template for this factory - set properties as needed and they will be copied to a final properties instance for the endpoint.
getContainerProperties() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
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.config.ContainerProperties
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.
getIdleEventInterval() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: How long the container has been idle.
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).
getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: The id of the listener (if @RabbitListener) or the container bean name.
getListenerTaskExecutor() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getMessageConverter() - Method in class org.springframework.kafka.core.KafkaTemplate: Return the message converter.
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.config.ContainerProperties
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
getPauseAfter() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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.config.ContainerProperties
getPort() - Method in class org.springframework.kafka.test.core.BrokerAddress
getProducerRecord() - Method in exception org.springframework.kafka.core.KafkaProducerException
getProducerRecord() - Method in class org.springframework.kafka.support.SendResult
getPropertyValue(Object, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.
getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: A typed version of KafkaTestUtils.getPropertyValue(Object, String).
getQueueDepth() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getRecordFilterStrategy() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRecordMetadata() - Method in class org.springframework.kafka.support.SendResult
getRecords(Consumer<K, V>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer for records.
getRecoveryCallback() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRecoveryCallback() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
getResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRetryTemplate() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRetryTemplate() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
getShutdownTimeout() - Method in class org.springframework.kafka.listener.config.ContainerProperties
getSingleRecord(Consumer<K, V>, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer, expecting a single record for the specified topic.
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.
getTopicPartitions() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: The TopicPartitions the container is listening to.
getTopicPartitions() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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.
getTopicPattern() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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.
getTopics() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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.support.TopicPartitionInitialOffset
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.ConcurrentKafkaListenerContainerFactory
initialOffset() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
INSTANCE - Static variable in class org.springframework.kafka.support.KafkaNull: Instance of KafkaNull.
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
isAckDiscarded() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
isAckOnError() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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
isInterestedInSuccess() - Method in interface org.springframework.kafka.support.ProducerListener: Return true if this listener is interested in success as well as failure.
isInterestedInSuccess() - Method in class org.springframework.kafka.support.ProducerListenerAdapter
isPauseEnabled() - Method in class org.springframework.kafka.listener.config.ContainerProperties
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
isSyncCommits() - Method in class org.springframework.kafka.listener.config.ContainerProperties

J

JsonDeserializer<T> - Class in org.springframework.kafka.support.serializer: Generic Deserializer for receiving JSON from Kafka and return Java objects.
JsonDeserializer() - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
JsonDeserializer(ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
JsonDeserializer(Class<T>) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
JsonDeserializer(Class<T>, ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonDeserializer
JsonSerializer<T> - Class in org.springframework.kafka.support.serializer: Generic Serializer for sending Java objects to Kafka as JSON.
JsonSerializer() - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer
JsonSerializer(ObjectMapper) - Constructor for class org.springframework.kafka.support.serializer.JsonSerializer

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.
KafkaEvent - Class in org.springframework.kafka.event: Base class for events.
KafkaEvent(Object) - Constructor for class org.springframework.kafka.event.KafkaEvent
KafkaException - Exception in org.springframework.kafka: The Spring Kafka specific NestedRuntimeException implementation.
KafkaException(String) - Constructor for exception org.springframework.kafka.KafkaException
KafkaException(String, Throwable) - Constructor for exception org.springframework.kafka.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>, ContainerProperties) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer: Construct an instance with the supplied configuration properties.
KafkaMessageListenerContainer(ConsumerFactory<K, V>, ContainerProperties, TopicPartitionInitialOffset...) - Constructor for class org.springframework.kafka.listener.KafkaMessageListenerContainer: Construct an instance with the supplied configuration properties and specific topics/partitions/initialOffsets.
KafkaNull - Class in org.springframework.kafka.support: This class represents NULL Kafka payload.
KafkaOperations<K,V> - Interface in org.springframework.kafka.core: The basic Kafka operations contract returning ListenableFutures.
KafkaProducerException - Exception in org.springframework.kafka.core: Exceptions when producing.
KafkaProducerException(ProducerRecord<?, ?>, String, Throwable) - Constructor for exception org.springframework.kafka.core.KafkaProducerException
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 and autoFlush false.
KafkaTemplate(ProducerFactory<K, V>, boolean) - Constructor for class org.springframework.kafka.core.KafkaTemplate: Create an instance using the supplied producer factory and autoFlush setting.
KafkaTestUtils - Class in org.springframework.kafka.test.utils: Kafka testing utilities.
key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

L

ListenerContainerIdleEvent - Class in org.springframework.kafka.event: An event that is emitted when a container is idle if the container is configured to do so.
ListenerContainerIdleEvent(Object, long, String, Collection<TopicPartition>) - Constructor for class org.springframework.kafka.event.ListenerContainerIdleEvent
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
logger - Variable in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
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 containing the message key when sending data to Kafka.
MessageConverter - Interface in org.springframework.kafka.support.converter: A 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 - 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(Method) - 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

objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer
OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders: The header for partition offset.
onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
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.FilteringAcknowledgingMessageListenerAdapter
onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter
onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter
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 - package org.springframework.kafka: Base package for kafka
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.event - package org.springframework.kafka.event: Application Events.
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.listener.config - package org.springframework.kafka.listener.config: Container configuration.
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.support.serializer - package org.springframework.kafka.support.serializer
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() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
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 containing the topic partition when sending data to Kafka.
PartitionOffset - Annotation Type in org.springframework.kafka.annotation: Used to add partition/initial offset information to a KafkaListener.
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
producerProps(KafkaEmbedded) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Set up test properties for an <Integer, String> producer.

R

RECEIVED_MESSAGE_KEY - Static variable in class org.springframework.kafka.support.KafkaHeaders: The header containing the message key for the received message.
RECEIVED_PARTITION_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders: The header containing the topic partition for the received message.
RECEIVED_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders: The header containing the topic from which the message was received.
RecordFilterStrategy<K,V> - Interface in org.springframework.kafka.listener.adapter: Implementations of this interface can signal that a record about to be delivered to a message listener should be discarded instead of being delivered.
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
RetryingAcknowledgingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: A retrying message listener adapter for MessageListeners.
RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K, V>, RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter: Construct an instance with the provided template and delegate.
RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K, V>, RetryTemplate, RecoveryCallback<Void>) - Constructor for class org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter: Construct an instance with the provided template, callback and delegate.
RetryingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter: A retrying message listener adapter for MessageListeners.
RetryingMessageListenerAdapter(MessageListener<K, V>, RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter: Construct an instance with the provided template and delegate.
RetryingMessageListenerAdapter(MessageListener<K, V>, RetryTemplate, RecoveryCallback<Void>) - Constructor for class org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter: Construct an instance with the provided template, callback and delegate.

S

send(String, V) - Method in interface org.springframework.kafka.core.KafkaOperations: Send the data to the provided topic with no key or partition.
send(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.
send(String, int, V) - Method in interface org.springframework.kafka.core.KafkaOperations: Send the data to the provided topic with the provided partition and no key.
send(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.
send(Message<?>) - Method in interface org.springframework.kafka.core.KafkaOperations: Send a message with routing information in message headers.
send(String, V) - Method in class org.springframework.kafka.core.KafkaTemplate
send(String, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
send(String, int, V) - Method in class org.springframework.kafka.core.KafkaTemplate
send(String, int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
send(Message<?>) - Method in class org.springframework.kafka.core.KafkaTemplate
sendDefault(V) - Method in interface org.springframework.kafka.core.KafkaOperations: Send the data to the default topic with no key or partition.
sendDefault(K, V) - Method in interface org.springframework.kafka.core.KafkaOperations: Send the data to the default topic with the provided key and no partition.
sendDefault(int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations: Send the data to the default topic with the provided key and partition.
sendDefault(V) - Method in class org.springframework.kafka.core.KafkaTemplate
sendDefault(K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
sendDefault(int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
senderProps(String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Set up test properties for an <Integer, String> producer.
SendResult<K,V> - Class in org.springframework.kafka.support: Result for a Listenablefuture after a send.
SendResult(ProducerRecord<K, V>, RecordMetadata) - Constructor for class org.springframework.kafka.support.SendResult
serialize(String, T) - Method in class org.springframework.kafka.support.serializer.JsonSerializer
setAckCount(int) - Method in class org.springframework.kafka.listener.config.ContainerProperties: 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.
setAckDiscarded(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Set to true to ack discards when a filter strategy is in use.
setAckDiscarded(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Set to true if the recordFilterStrategy is in use.
setAckMode(AbstractMessageListenerContainer.AckMode) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the ack mode to use when auto ack (in the configuration properties) is false.
setAckOnError(boolean) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set whether the container should ack messages that throw exceptions or not.
setAckTime(long) - Method in class org.springframework.kafka.listener.config.ContainerProperties: 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
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
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
setClientIdSuffix(String) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer: Set a suffix to add to the client.id consumer property (if the consumer factory supports it).
setCommitCallback(OffsetCommitCallback) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the commit callback; by default a simple logging callback is used to log success at DEBUG level and failures at ERROR level.
setConcurrency(Integer) - Method in class org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory: 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.
setConsumerRebalanceListener(ConsumerRebalanceListener) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the user defined ConsumerRebalanceListener implementation.
setConsumerTaskExecutor(AsyncListenableTaskExecutor) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the executor for threads that poll the consumer.
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.listener.config.ContainerProperties: Set the error handler to call when the listener throws an exception.
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
setIdleEventInterval(Long) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the idle event interval; when set, an event is emitted if a poll returns no records and this interval has elapsed since a record was returned.
setIncludeContents(boolean) - Method in class org.springframework.kafka.support.LoggingProducerListener: Whether the log message should include the contents (key and payload).
setKeyDeserializer(Deserializer<K>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
setKeySerializer(Serializer<K>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
setListenerTaskExecutor(AsyncListenableTaskExecutor) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the executor for threads that invoke the listener.
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) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Set the message converter to use if dynamic argument type matching is needed.
setMessageConverter(MessageConverter) - Method in class org.springframework.kafka.core.KafkaTemplate: Set the message converter to use.
setMessageConverter(MessageConverter) - 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.config.ContainerProperties: 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.
setPauseAfter(long) - Method in class org.springframework.kafka.listener.config.ContainerProperties: When using Kafka group management and ContainerProperties.setPauseEnabled(boolean) is true, set the delay after which the consumer should be paused.
setPauseEnabled(boolean) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set to true to avoid rebalancing when this consumer is slow or throws a qualifying exception - pause the consumer.
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.listener.config.ContainerProperties: Set 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.
setQueueDepth(int) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the queue depth for handoffs from the consumer thread to the listener thread.
setRecordFilterStrategy(RecordFilterStrategy<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Set the record filter strategy.
setRecordFilterStrategy(RecordFilterStrategy<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Set a RecordFilterStrategy implementation.
setRecoveryCallback(RecoveryCallback<Void>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Set a callback to be used with the retryTemplate.
setRecoveryCallback(RecoveryCallback<Void>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Set a callback to be used with the retryTemplate.
setRetryTemplate(RetryTemplate) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory: Set a retryTemplate.
setRetryTemplate(RetryTemplate) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Set a retryTemplate.
setRunning(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
setShutdownTimeout(long) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set the timeout for shutting down the container.
setSyncCommits(boolean) - Method in class org.springframework.kafka.listener.config.ContainerProperties: Set whether or not to call consumer.commitSync() or commitAsync() when the container is responsible for commits.
setTopicPartitions(TopicPartitionInitialOffset...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Set the topicPartitions 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, MessageConverter) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
setupListenerContainer(MessageListenerContainer, MessageConverter) - 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.
setValueDeserializer(Deserializer<V>) - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
setValueSerializer(Serializer<V>) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
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
SPRING_EMBEDDED_KAFKA_BROKERS - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
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
StringJsonMessageConverter - Class in org.springframework.kafka.support.converter: JSON Message converter - String on output, String or byte[] on input.
StringJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.StringJsonMessageConverter
StringJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.StringJsonMessageConverter

T

targetType - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
toMessage(ConsumerRecord<?, ?>, Acknowledgment, Type) - Method in interface org.springframework.kafka.support.converter.MessageConverter: Convert a ConsumerRecord to a Message.
toMessage(ConsumerRecord<?, ?>, Acknowledgment, Type) - 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 containing the topic when sending data to Kafka.
topic() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
TopicPartition - Annotation Type in org.springframework.kafka.annotation: Used to add topic/partition information to a KafkaListener.
topicPartition() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
TopicPartitionInitialOffset - Class in org.springframework.kafka.support: A configuration container to represent a topic name, partition number and, optionally, an initial offset for it.
TopicPartitionInitialOffset(String, int) - Constructor for class org.springframework.kafka.support.TopicPartitionInitialOffset
TopicPartitionInitialOffset(String, int, Long) - Constructor for class org.springframework.kafka.support.TopicPartitionInitialOffset
toString() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
toString() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent
toString() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
toString() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
toString() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
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

waitForAssignment(Object, int) - Static method in class org.springframework.kafka.test.utils.ContainerTestUtils: Wait until the container has the required number of assigned partitions.
waitUntilSynced(String, int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded

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