- getAckCount() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Return the count.
- getAckMode() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getAckTime() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Return the ack time.
- getAssignedPartitions() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Return the TopicPartitions currently assigned to this container,
either explicitly or by Kafka; may be null if not assigned yet.
- getBean() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
- getBean() - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Return the bean for this handler.
- getBean() - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
-
- getBeanExpressionContext() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- getBeanFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- getBeanName() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getConcurrency() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
- getConsumerFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
- getContainers() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
- 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
-
- getErrorHandler() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getGroup() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- getGroup() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the group of this endpoint or null if not in a group.
- getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Determine the InvocableHandlerMethod for the provided type.
- getId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- getId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the id of this endpoint.
- getListenerContainer(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- getListenerContainerIds() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- getListenerContainers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- getMessageConverter() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
- getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Return the custom MessageHandlerMethodFactory to use, if any.
- getMessageHandlerMethodFactory() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Return the MessageHandlerMethodFactory.
- getMessageListener() - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint
-
Return the
MessageListener to invoke when a message matching
the endpoint is received.
- getMessageListener() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getMethod() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
- getMethodAsString(Object) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
-
- getMethodNameFor(Object) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
-
Return a string representation of the method that will be invoked for this payload.
- getOrder() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
- getPhase() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- getPhase() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getPollTimeout() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
Return the poll timeout.
- getResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- getTaskExecutor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- getTopicPartitions() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topicPartitions for this endpoint.
- getTopicPartitions() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topicPartitions for this endpoint.
- getTopicPattern() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topicPattern for this endpoint.
- getTopicPattern() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topicPattern for this endpoint.
- getTopics() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Return the topics for this endpoint.
- getTopics() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Return the topics for this endpoint.
- setAckCount(Integer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify an ackCount to use.
- setAckCount(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setAckMode(AbstractMessageListenerContainer.AckMode) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
- setAckMode(AbstractMessageListenerContainer.AckMode) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
The ack mode to use when auto ack (in the configuration properties) is
false.
- setAckTime(long) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setApplicationContext(ApplicationContext) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- setAutoStartup(Boolean) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify an autoStartup boolean flag.
- setAutoStartup(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setBean(Object) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the object instance that should manage this endpoint.
- setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
- setBeanName(String) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setConcurrency(Integer) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory
-
Specify the container concurrency.
- setConcurrency(int) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
- setConsumerFactory(ConsumerFactory<K, V>) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
- setContainerFactory(KafkaListenerContainerFactory<?>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
- setContainerFactoryBeanName(String) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
- setContainerFactoryBeanName(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
- 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
-
- setEndpointRegistry(KafkaListenerEndpointRegistry) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
- setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
- setErrorHandler(ErrorHandler) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setGenerateMessageId(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Generate Message ids for produced messages.
- setGenerateTimestamp(boolean) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
-
Generate timestamp for produced messages.
- setGroup(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the group for the corresponding listener container.
- setHandlerMethod(HandlerAdapter) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the
HandlerAdapter to use to invoke the method
processing an incoming
ConsumerRecord.
- setId(String) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- setIncludeContents(boolean) - Method in class org.springframework.kafka.support.LoggingProducerListener
-
Whether the log message should include the contents (key and payload).
- setMaxContentLogged(int) - Method in class org.springframework.kafka.support.LoggingProducerListener
-
The maximum amount of data to be logged for either key or password.
- setMessageConverter(MessageConverter<K, V>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Set the MessageConverter.
- setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
-
Set the MessageHandlerMethodFactory to use to configure the message
listener responsible to serve an endpoint detected by this processor.
- setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar
-
Set the MessageHandlerMethodFactory to use to configure the message
listener responsible to serve an endpoint detected by this processor.
- setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the MessageHandlerMethodFactory to use to build the
InvocableHandlerMethod responsible to manage the invocation
of this endpoint.
- setMessageListener(MessageListener<K, V>) - Method in class org.springframework.kafka.config.SimpleKafkaListenerEndpoint
-
Set the
MessageListener to invoke when a message matching
the endpoint is received.
- setMessageListener(Object) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setMethod(Method) - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
-
Set the method to invoke to process a message managed by this endpoint.
- setPhase(int) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify a phase to use.
- setPhase(int) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setPollTimeout(Long) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify a pollTimeout to use.
- setPollTimeout(long) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
The max time to block in the consumer waiting for records.
- setProducerListener(ProducerListener<K, V>) - Method in class org.springframework.kafka.core.KafkaTemplate
-
Set a
ProducerListener which will be invoked when Kafka acknowledges
a send operation.
- setRecentOffset(Long) - Method in class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory
-
Specify the offset lag from the end of commit.
- setRecentOffset(long) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
-
Set the offset to this number of records back from the latest when starting.
- setRecentOffset(long) - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
-
Set the offset to this number of records back from the latest when starting.
- setRunning(boolean) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setTaskExecutor(Executor) - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
-
Specify an Executor to use.
- setTaskExecutor(Executor) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setTopicPartitions(TopicPartition...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topics to use.
- setTopicPattern(Pattern) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topic pattern to use.
- setTopics(String...) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
Set the topics to use.
- setupListenerContainer(MessageListenerContainer) - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
-
- setupListenerContainer(MessageListenerContainer) - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint
-
Setup the specified message listener container with the model
defined by this endpoint.
- setupMessageListener(Object) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- setupMessageListener(Object) - Method in interface org.springframework.kafka.listener.MessageListenerContainer
-
Setup the message listener to use.
- SimpleKafkaListenerContainerFactory<K,V> - Class in org.springframework.kafka.config
-
- SimpleKafkaListenerContainerFactory() - Constructor for class org.springframework.kafka.config.SimpleKafkaListenerContainerFactory
-
- SimpleKafkaListenerEndpoint<K,V> - Class in org.springframework.kafka.config
-
- SimpleKafkaListenerEndpoint() - Constructor for class org.springframework.kafka.config.SimpleKafkaListenerEndpoint
-
- start() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- start() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
- start() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- stop() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- stop(Runnable) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
-
- stop() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
-
- stop() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- stop(Runnable) - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
-
- syncConvertAndSend(V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with no key or partition;
wait for result.
- syncConvertAndSend(K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with the provided key and no partition;
wait for result.
- syncConvertAndSend(int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the default topic with the provided key and partition.
- syncConvertAndSend(String, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with no key or partition.;
wait for result.
- syncConvertAndSend(String, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with the provided key and no partition;
wait for result.
- syncConvertAndSend(String, int, K, V) - Method in interface org.springframework.kafka.core.KafkaOperations
-
Send the data to the provided topic with the provided key and partition;
wait for result.
- syncConvertAndSend(V) - Method in class org.springframework.kafka.core.KafkaTemplate
-
- syncConvertAndSend(K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
-
- syncConvertAndSend(int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
-
- syncConvertAndSend(String, V) - Method in class org.springframework.kafka.core.KafkaTemplate
-
- syncConvertAndSend(String, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
-
- syncConvertAndSend(String, int, K, V) - Method in class org.springframework.kafka.core.KafkaTemplate
-