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

A

AbstractFilteringMessageListener<K,V,T> - Class in org.springframework.kafka.listener.adapter
An abstract message listener adapter that implements record filter logic via a RecordFilterStrategy.
AbstractFilteringMessageListener(T, 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
 
AbstractMessageListenerAdapter<K,V,T> - Class in org.springframework.kafka.listener.adapter
Top level class for all listener adapters.
AbstractMessageListenerAdapter(T) - Constructor for class org.springframework.kafka.listener.adapter.AbstractMessageListenerAdapter
 
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,T> - Class in org.springframework.kafka.listener.adapter
Base class for retrying message listener adapters.
AbstractRetryingMessageListenerAdapter(T, RetryTemplate) - Constructor for class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
Construct an instance with the supplied retry template.
AbstractRetryingMessageListenerAdapter(T, 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

BatchAcknowledgingMessageListener<K,V> - Interface in org.springframework.kafka.listener
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
BatchErrorHandler - Interface in org.springframework.kafka.listener
Handles errors thrown during the execution of a BatchMessageListener.
BatchLoggingErrorHandler - Class in org.springframework.kafka.listener
Simple handler that invokes a LoggingErrorHandler for each record.
BatchLoggingErrorHandler() - Constructor for class org.springframework.kafka.listener.BatchLoggingErrorHandler
 
BatchMessageConverter - Interface in org.springframework.kafka.support.converter
A Kafka-specific Message converter strategy.
BatchMessageListener<K,V> - Interface in org.springframework.kafka.listener
Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
BatchMessagingMessageConverter - Class in org.springframework.kafka.support.converter
A Messaging MessageConverter implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload.
BatchMessagingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
 
BatchMessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive batches of messages.
BatchMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
 
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

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
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
 
ConsumerSeekAware - Interface in org.springframework.kafka.listener
Listeners that implement this interface are provided with a ConsumerSeekAware.ConsumerSeekCallback which can be used to perform a seek operation.
ConsumerSeekAware.ConsumerSeekCallback - Interface in org.springframework.kafka.listener
A callback that a listener can invoke to seek to a specific offset.
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() - Method in interface org.springframework.kafka.core.ConsumerFactory
 
createConsumer() - 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
 
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
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
 
createMessageListenerInstance(MessageConverter) - 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
 
delegate - Variable in class org.springframework.kafka.listener.adapter.AbstractMessageListenerAdapter
 
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
 
determineInferredType(Method) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
Subclasses can override this method to use a different mechanism to determine the target type of the payload conversion.
doInKafka(Producer<K, V>) - Method in interface org.springframework.kafka.core.KafkaOperations.ProducerCallback
 
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.
execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in interface org.springframework.kafka.core.KafkaOperations
Execute some arbitrary operation(s) on the producer and return the result.
execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in class org.springframework.kafka.core.KafkaTemplate
 
extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
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.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
 

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.
FilteringBatchAcknowledgingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
A BatchAcknowledgingMessageListener adapter that implements filter logic via a RecordFilterStrategy.
FilteringBatchAcknowledgingMessageListenerAdapter(BatchAcknowledgingMessageListener<K, V>, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.FilteringBatchAcknowledgingMessageListenerAdapter
Create an instance with the supplied strategy and delegate listener; when all messages in a batch are discarded, an empty list is passed to the delegate so it can decide whether or not to acknowledge.
FilteringBatchAcknowledgingMessageListenerAdapter(BatchAcknowledgingMessageListener<K, V>, RecordFilterStrategy<K, V>, boolean) - Constructor for class org.springframework.kafka.listener.adapter.FilteringBatchAcknowledgingMessageListenerAdapter
Create an instance with the supplied strategy, delegate listener and discard action.
FilteringBatchMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
A BatchMessageListener adapter that implements filter logic via a RecordFilterStrategy.
FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V>, RecordFilterStrategy<K, V>) - Constructor for class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
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
Flush the producer.
fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress
 
fromMessage(Message<?>, String) - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter
Convert a message to a producer record.
fromMessage(Message<?>, String) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
 
fromMessage(Message<?>, String) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
 
fromMessage(Message<?>, String) - Method in interface org.springframework.kafka.support.converter.RecordMessageConverter
Convert a message to a producer record.

G

GenericAcknowledgingMessageListener<T> - Interface in org.springframework.kafka.listener
Top level interface for acknowledging listener types.
GenericErrorHandler<T> - Interface in org.springframework.kafka.listener
A generic error handler.
GenericMessageListener<T> - Interface in org.springframework.kafka.listener
Top level interface for listener types using container or auto commits.
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.
getBatchMessageConverter() - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
Return the BatchMessagingMessageConverter for this listener, being able to convert Message.
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
 
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
 
getEndpointRegistry() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
Return the KafkaListenerEndpointRegistry instance for this registrar, may be null.
getGenericErrorHandler() - 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.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
getQueueDepth() - Method in class org.springframework.kafka.listener.config.ContainerProperties
 
getRawHeaders() - Method in class org.springframework.kafka.support.converter.KafkaMessageHeaders
 
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
 
getType() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
Returns the inferred type for conversion or, if null, the fallbackType.
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, ConsumerRecords<?, ?>) - Method in class org.springframework.kafka.listener.BatchLoggingErrorHandler
 
handle(Exception, ConsumerRecord<?, ?>) - Method in interface org.springframework.kafka.listener.ErrorHandler
 
handle(Exception, T) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
 
handle(Exception, ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.listener.LoggingErrorHandler
 
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
 
invokeHandler(Object, Acknowledgment, Message<?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
Invoke the handler, wrapping any exception to a ListenerExecutionFailedException with a dedicated error message.
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
 
isBatchListener() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
Return true if this endpoint creates a batch listener.
isBatchListener() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
Return true if this endpoint creates a batch listener.
isConsumerRecordList() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
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
 
isMessageList() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
isPauseEnabled() - Method in class org.springframework.kafka.listener.config.ContainerProperties
 
isRelativeToCurrent() - Method in class org.springframework.kafka.support.TopicPartitionInitialOffset
 
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
 
KafkaDataListener<T> - Interface in org.springframework.kafka.listener
Marker interface for all listeners.
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
 
KafkaMessageHeaders - Class in org.springframework.kafka.support.converter
Overload of message headers configurable for adding id and timestamp headers.
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.
KafkaOperations.ProducerCallback<K,V,T> - Interface in org.springframework.kafka.core
A callback for executing arbitrary operations on the Producer.
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.AbstractMessageListenerAdapter
 
logger - Variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
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 top level interface for message converters.
MessageListener<K,V> - Interface in org.springframework.kafka.listener
Listener for handling individual incoming Kafka messages.
MessageListenerContainer - Interface in org.springframework.kafka.listener
Internal abstraction used by the framework representing a message listener container.
MessagingMessageConverter - Class in org.springframework.kafka.support.converter
A Messaging MessageConverter implementation for a message listener that receives individual messages.
MessagingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.MessagingMessageConverter
 
MessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
An abstract MessageListener adapter providing the necessary infrastructure to extract the payload of a Message.
MessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
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
 
metrics() - Method in interface org.springframework.kafka.core.KafkaOperations
See Producer.metrics().
metrics() - Method in class org.springframework.kafka.core.KafkaTemplate
 
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
 
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractMessageListenerAdapter
 
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
If the container is configured to emit idle container events, this method is called when the container idle event is emitted - allowing a seek operation.
onMessage(List<ConsumerRecord<K, V>>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
Kafka MessageListener entry point.
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
 
onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.FilteringAcknowledgingMessageListenerAdapter
 
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchAcknowledgingMessageListenerAdapter
 
onMessage(List<ConsumerRecord<K, V>>) - Method in class org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter
 
onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter
 
onMessage(ConsumerRecord<K, V>) - Method in class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter
Kafka MessageListener entry point.
onMessage(ConsumerRecord<K, V>, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter
 
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(T, Acknowledgment) - Method in interface org.springframework.kafka.listener.GenericAcknowledgingMessageListener
Invoked with data from kafka.
onMessage(T) - Method in interface org.springframework.kafka.listener.GenericMessageListener
Invoked with data from kafka.
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractMessageListenerAdapter
 
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
When using group management, called when partition assignments change.
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.
partitionsFor(String) - Method in interface org.springframework.kafka.core.KafkaOperations
See Producer.partitionsFor(String).
partitionsFor(String) - Method in class org.springframework.kafka.core.KafkaTemplate
 
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.
RecordMessageConverter - Interface in org.springframework.kafka.support.converter
A Kafka-specific Message converter strategy.
RecordMessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter
A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
RecordMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter
 
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.
registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.AbstractMessageListenerAdapter
 
registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware
Register the callback to use when seeking at some arbitrary time.
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

seek(String, int, long) - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
Queue a seek operation to the consumer.
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
 
setBatchListener(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
Set to true if this endpoint should create a batch listener.
setBatchListener(boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
Set to true if this endpoint should create a batch listener.
setBatchMessageConverter(BatchMessageConverter) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
Set the BatchMessageConverter.
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
 
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.
setFallbackType(Class<?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
Set a fallback type to use when using a type-aware message converter and this adapter cannot determine the inferred type from the method.
setGenerateMessageId(boolean) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
Generate Message ids for produced messages.
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.BatchMessagingMessageConverter
Generate timestamp for produced messages.
setGenerateTimestamp(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
Generate timestamp for produced messages.
setGenericErrorHandler(GenericErrorHandler<?>) - Method in class org.springframework.kafka.listener.config.ContainerProperties
Set the error handler to call when the listener throws an exception.
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(RecordMessageConverter) - Method in class org.springframework.kafka.core.KafkaTemplate
Set the message converter to use.
setMessageConverter(RecordMessageConverter) - 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(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
 
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(List<ConsumerRecord<?, ?>>, Acknowledgment, Type) - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter
Convert a list of ConsumerRecord to a Message.
toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
 
toMessage(ConsumerRecord<?, ?>, Acknowledgment, Type) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
 
toMessage(ConsumerRecord<?, ?>, Acknowledgment, Type) - Method in interface org.springframework.kafka.support.converter.RecordMessageConverter
Convert a ConsumerRecord to a Message.
toMessagingMessage(List, Acknowledgment) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter
 
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
Construct an instance with no initial offset management.
TopicPartitionInitialOffset(String, int, Long) - Constructor for class org.springframework.kafka.support.TopicPartitionInitialOffset
Construct an instance with the provided initial offset with TopicPartitionInitialOffset.isRelativeToCurrent() false.
TopicPartitionInitialOffset(String, int, Long, boolean) - Constructor for class org.springframework.kafka.support.TopicPartitionInitialOffset
Construct an instance with the provided initial offset.
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 
Skip navigation links
Spring Kafka