G-Index (Spring for Apache Kafka 3.3.0 API)

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

G

generateValues() - Method in class org.springframework.kafka.retrytopic.BackOffValuesGenerator
GenericMessageListener<T> - Interface in org.springframework.kafka.listener: Top level interface for listeners.
GenericMessageListenerContainer<K,V> - Interface in org.springframework.kafka.listener: Generic message listener container; adds parameters.
get() - Method in class org.springframework.kafka.core.ABSwitchCluster
get() - Method in class org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture
get(long, TimeUnit) - Method in class org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture
getAckCount() - Method in class org.springframework.kafka.listener.ContainerProperties
getAckMode() - Method in class org.springframework.kafka.listener.ContainerProperties
getAckTime() - Method in class org.springframework.kafka.listener.ContainerProperties
getAdminConfig() - Method in class org.springframework.kafka.core.KafkaAdmin
getAdviceChain() - Method in class org.springframework.kafka.listener.ContainerProperties: A chain of listener Advices.
getAfterRollbackProcessor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Return the currently configured AfterRollbackProcessor.
getAllListenerContainers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry: Return all MessageListenerContainer instances including those managed by this registry and those declared as beans in the application context.
getAllListenerContainers() - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return all MessageListenerContainer instances including those managed by this registry and those declared as beans in the application context.
getApplicationContext() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getApplicationEventPublisher() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Get the event publisher.
getAssignedPartitions() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
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.
getAssignedPartitions() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: Return the assigned topics/partitions for this container.
getAssignedReplyTopicPartitions() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate: Return the topics/partitions assigned to the replying listener container.
getAssignmentCommitOption() - Method in class org.springframework.kafka.listener.ContainerProperties
getAssignmentsByClientId() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
getAssignmentsByClientId() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer
getAssignmentsByClientId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: Return the assigned topics/partitions for this container, by client.id.
getAuthExceptionRetryInterval() - Method in class org.springframework.kafka.listener.ConsumerProperties: Get the authentication/authorization retry interval.
getAutoStartup() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getAutoStartup() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the autoStartup for this endpoint's container.
getBatchInterceptor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getBatchListener() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Return the current batch listener flag for this endpoint, or null if not explicitly set.
getBatchListener() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the current batch listener flag for this endpoint, or null if not explicitly set.
getBatchMessageConverter() - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter: Return the BatchMessagingMessageConverter for this listener, being able to convert Message.
getBatchToRecordAdapter() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
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
getBean(String, Class<T>) - Method in class org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
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: Return the bean name.
getBeanName() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext: Return the template's bean name.
getBeanResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getBlockingRetryDeliveryAttempt() - Method in class org.springframework.kafka.support.KafkaMessageHeaderAccessor: Access the header value when the blocking delivery attempt header is present.
getBootstrapServers() - Method in class org.springframework.kafka.core.KafkaResourceFactory
getBroker() - Static method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
getBrokerAddress(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getBrokerAddresses() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getBrokersAsString() - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker: Get the bootstrap server addresses as a String.
getBrokersAsString() - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
getBrokersAsString() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getCache() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getCache(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getCallbacksAndTopics() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware: Return the currently registered callbacks and their associated TopicPartition(s).
getCharset() - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
getCharset() - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer: Get the configured charset.
getCharset() - Method in class org.springframework.kafka.support.serializer.ToStringSerializer: Get the configured charset.
getClassIdFieldName() - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
getClassifier() - Method in class org.springframework.kafka.listener.ExceptionClassifier: Return the exception classifier.
getClassLoader() - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
getClientId() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the client id.
getClientId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the client id.
getClientIdPrefix() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getClientIdPrefix() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the client id prefix for the container; it will be suffixed by '-n' to provide a unique id when concurrency is used.
getClientIdPrefix(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory.RetryTopicNamesProvider: Return the clientId prefix that will override the endpoint's clientId prefix.
getClientIdPrefix(KafkaListenerEndpoint) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getCluster() - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
getClusterId() - Method in class org.springframework.kafka.core.KafkaAdmin: Get the clusterId property.
getCommitCallback() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the commit callback.
getCommitLogLevel() - Method in class org.springframework.kafka.listener.ConsumerProperties: The level at which to log offset commits.
getCommitRetries() - Method in class org.springframework.kafka.listener.ConsumerProperties: The number of retries allowed when a RetriableCommitFailedException is thrown by the consumer when using ConsumerProperties.setSyncCommits(boolean) set to true.
getCommonErrorHandler() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Get the CommonErrorHandler.
getConcurrency() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getConcurrency() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the concurrency for this endpoint's container.
getConcurrency() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
getConcurrency() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
getConfigurationProperties() - Method in interface org.springframework.kafka.core.ConsumerFactory: Return an unmodifiable reference to the configuration map for this factory.
getConfigurationProperties() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
getConfigurationProperties() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory: Return an unmodifiable reference to the configuration map for this factory.
getConfigurationProperties() - Method in class org.springframework.kafka.core.KafkaAdmin
getConfigurationProperties() - Method in interface org.springframework.kafka.core.KafkaAdminOperations: Get an unmodifiable copy of this admin's configuration.
getConfigurationProperties() - Method in interface org.springframework.kafka.core.ProducerFactory: Return an unmodifiable reference to the configuration map for this factory.
getConfigurationProperties() - Method in class org.springframework.kafka.mock.MockConsumerFactory
getConsumer() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent
getConsumer() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: Retrieve the consumer.
getConsumer() - Method in class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent: Retrieve the consumer.
getConsumer() - Method in class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent: Retrieve the consumer.
getConsumer() - Method in class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent: Retrieve the consumer.
getConsumer() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent: Retrieve the consumer.
getConsumerFactory() - Method in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory
getConsumerForTimingAdjustment() - Method in class org.springframework.kafka.listener.KafkaConsumerBackoffManager.Context
getConsumerGroup() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the consumer group.
getConsumerGroupId() - Static method in class org.springframework.kafka.support.KafkaUtils: Get the group id for the consumer bound to this thread.
getConsumerProperties() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getConsumerProperties() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Get the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
getConsumerRebalanceListener() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the rebalance listener.
getConsumerStartTimeout() - Method in class org.springframework.kafka.listener.ContainerProperties
getContainer(Class<T>) - Method in class org.springframework.kafka.event.KafkaEvent: Get the container for which the event was published, which will be the parent container if the source that emitted the event is a child container, or the source itself otherwise.
getContainerFor(String, int) - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer
getContainerFor(String, int) - Method in interface org.springframework.kafka.listener.MessageListenerContainer: If this container has child containers, return the child container that is assigned the topic/partition.
getContainerPostProcessor() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getContainerPostProcessor() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the ContainerPostProcessor for this endpoint, or null if not explicitly set.
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
getContainerProperties() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: Return the container properties for this container.
getContainers() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer: Return the list of KafkaMessageListenerContainers created by this container.
getContentClassIdFieldName() - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
getContext() - Method in class org.springframework.kafka.streams.HeaderEnricherProcessor.Container
getContextualName(KafkaRecordReceiverContext) - Method in class org.springframework.kafka.support.micrometer.KafkaListenerObservation.DefaultKafkaListenerObservationConvention
getContextualName(KafkaRecordSenderContext) - Method in class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getCorrelationHeaderName() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate: Return the correlation header name.
getCorrelationId() - Method in class org.springframework.kafka.requestreply.CorrelationKey
getCreateOrModifyTopic() - Method in class org.springframework.kafka.core.KafkaAdmin: Return the predicate used to determine whether a NewTopic should be considered for creation or modification.
getCurrentKafkaStreamsApplicationHostInfo() - Method in class org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService: Retrieve the current HostInfo where this Kafka Streams application is running on.
getCurrentOffset(String, String, String, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Get the current offset and metadata for the provided group/topic/partition.
getCurrentOffset(AdminClient, String, String, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Get the current offset and metadata for the provided group/topic/partition.
getCustomMethodArgumentResolvers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar: Return the list of HandlerMethodArgumentResolver.
getData() - Method in exception org.springframework.kafka.support.serializer.DeserializationException: Get the data that failed deserialization (value or key).
getData() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
getDefaultMethod() - Method in class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint: Get a default method.
getDefaultMethod() - Method in class org.springframework.kafka.support.EndpointHandlerMultiMethod: Return the default method.
getDefaultPredicate(Collection<T>, Collection<T>) - Method in class org.springframework.kafka.support.AllowDenyCollectionManager
getDefaultReplyTimeout() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate: Return the reply timeout used if no replyTimeout is provided in the ReplyingKafkaTemplate.sendAndReceive(ProducerRecord, Duration) call.
getDefaultReplyTopicExpression() - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils: Return the default expression when no SendTo value is present.
getDefaultTopic() - Method in class org.springframework.kafka.core.KafkaTemplate: The default topic for send methods where a topic is not provided.
getDelegate() - Method in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
getDelegate() - Method in class org.springframework.kafka.listener.adapter.ConvertingMessageListener
getDelegate() - Method in interface org.springframework.kafka.listener.DelegatingMessageListener: Return the delegate.
getDelegates() - Method in class org.springframework.kafka.support.CompositeProducerListener
getDestination() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext: Return the destination topic.
getDestinationDelay() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
getDestinationName() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
getDestinationPartitions() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
getDestinationTimeout() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
getDestinationTopicByName(String, String) - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver
getDestinationTopicByName(String, String) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicContainer: Returns the DestinationTopic instance registered for that topic.
getDestinationTopicProperties() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
getDltFor(String, String) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicContainer: Deprecated, for removal: This API element is subject to removal in a future version.
Replaced by DestinationTopicContainer.getDltFor(String, String, Exception)
getDltFor(String, String, Exception) - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver
getDltFor(String, String, Exception) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicContainer: Returns the DestinationTopic instance registered as DLT for the given topic taking into consideration the exception thrown, or null if none is found.
getDltHandlerMethod() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
getDltSuffix() - Method in class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory.DestinationTopicSuffixes
getDueTimestamp() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getDueTimestamp() - Method in class org.springframework.kafka.listener.KafkaConsumerBackoffManager.Context
getEmbeddedKafka() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule: Return an underlying delegator EmbeddedKafkaBroker instance.
getEndOffsets(Consumer<?, ?>, String, Integer...) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Return the end offsets of the requested topic/partitions
getEndpointDescription() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Return a description for this endpoint.
getEndpointDescription() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
getEndpointHandlerMethod(MethodKafkaListenerEndpoint<?, ?>, RetryTopicConfiguration, DestinationTopic.Properties) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer
getEndpointId(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory.RetryTopicNamesProvider: Return the endpoint id that will override the endpoint's current id.
getEndpointId(KafkaListenerEndpoint) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getEndpointRegistrar() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor: Return the KafkaListenerEndpointRegistrar.
getEndpointRegistry() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar: Return the KafkaListenerEndpointRegistry instance for this registrar, may be null.
getEosMode() - Method in class org.springframework.kafka.listener.ContainerProperties: Get the exactly once semantics mode.
getException() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
getExceptionCauseFqcn() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the exception cause.
getExceptionFqcn() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the value exception class.
getExceptionFromHeader(ConsumerRecord<?, ?>, String, LogAccessor) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils: Extract a DeserializationException from the supplied header name, if present.
getExceptionInfo() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames: The header names for the exception headers.
getExceptionMessage() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the exception message.
getExceptionStacktrace() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the exception stack trace.
getFailedProducerRecord() - Method in exception org.springframework.kafka.core.KafkaProducerException: Return the failed producer record.
getFailureTracker() - Method in class org.springframework.kafka.listener.FailedRecordProcessor: Return the failed record tracker.
getFallbackBatchHandler() - Method in class org.springframework.kafka.listener.FailedBatchProcessor: Return the fallback batch error handler.
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.
getGroup(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory.RetryTopicNamesProvider: Return the group that will override the endpoint's group.
getGroup(KafkaListenerEndpoint) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getGroupId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getGroupId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the groupId of this endpoint - if present, overrides the group.id property of the consumer factory.
getGroupId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getGroupId() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the container's group id.
getGroupId() - Method in interface org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback: Retrieve the group ID associated with this consumer seek callback, if available.
getGroupId() - Method in exception org.springframework.kafka.listener.ListenerExecutionFailedException: Return the consumer group.id property of the container that threw this exception.
getGroupId() - Method in interface org.springframework.kafka.listener.ListenerMetadata: Return the group id.
getGroupId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: Return the group.id property for this container whether specifically set on the container or via a consumer property on the consumer factory.
getGroupId() - Static method in interface org.springframework.kafka.support.converter.MessageConverter: Get the thread bound group id.
getGroupId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the consumer group id.
getGroupId(KafkaListenerEndpoint) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory.RetryTopicNamesProvider: Return the groupId that will override the endpoint's groupId.
getGroupId(KafkaListenerEndpoint) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getHandlerForPayload(Class<?>) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler: Determine the InvocableHandlerMethod for the provided type.
getHeader(String, Class<T>) - Method in class org.springframework.kafka.support.KafkaMessageHeaderAccessor: Get a header value with a specific type.
getHeaderNames() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: Deprecated, for removal: This API element is subject to removal in a future version.
since 3.0.9 - provide a supplier instead.
getHeaders() - Method in exception org.springframework.kafka.support.serializer.DeserializationException: Get the headers.
getHeaders() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
getHeaderValue() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
getHighCardinalityKeyValues(KafkaRecordReceiverContext) - Method in class org.springframework.kafka.support.micrometer.KafkaListenerObservation.DefaultKafkaListenerObservationConvention
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.
getIdClassMapping() - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
getIdleBeforeDataMultiplier() - Method in class org.springframework.kafka.listener.ContainerProperties: Multiply the ContainerProperties.setIdleEventInterval(Long) by this value until at least one record is received.
getIdleBetweenPolls() - Method in class org.springframework.kafka.listener.ContainerProperties
getIdleEventInterval() - Method in class org.springframework.kafka.listener.ContainerProperties: Return the idle event interval.
getIdlePartitionEventInterval() - Method in class org.springframework.kafka.listener.ContainerProperties: Return the idle partition event interval.
getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: How long the container has been idle.
getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent: How long the container was idle.
getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent: How long the partition has been idle.
getIdleTime() - Method in class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent: How long the partition was idle.
getIndex() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException: Return the index in the batch of the failed record.
getInvocationResultFor(Object, Object) - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler: Return the result of a method invocation by providing a result and payload.
getInvocationResultFor(Object, Object) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
getKafkaAdmin() - Method in class org.springframework.kafka.core.KafkaTemplate: Return the KafkaAdmin, used to find the cluster id for observation, if present.
getKafkaAdmin() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Return the KafkaAdmin, used to find the cluster id for observation, if present.
getKafkaAwareTransactionManager() - Method in class org.springframework.kafka.listener.ContainerProperties
getKafkaConsumerProperties() - Method in class org.springframework.kafka.listener.ConsumerProperties: Get the consumer properties that will be merged with the consumer properties provided by the consumer factory; properties here will supersede any with the same name(s) in the consumer factory.
getKafkaOperations() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
getKafkaServer(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getKafkaServers() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getKafkaStreams() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean: Get a managed by this StreamsBuilderFactoryBean KafkaStreams instance.
getKafkaStreamsApplicationHostInfo(String, K, Serializer<K>) - Method in class org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService: Retrieve the HostInfo where the provided store and key are hosted on.
getKey() - Method in class org.springframework.kafka.streams.HeaderEnricherProcessor.Container
getKeyClassIdFieldName() - Method in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper
getKeyDeserializer() - Method in interface org.springframework.kafka.core.ConsumerFactory: Return the configured key deserializer (if provided as an object instead of a class name in the properties).
getKeyDeserializer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
getKeyExceptionFqcn() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the key exception class.
getKeyExceptionMessage() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the key exception message.
getKeyExceptionStacktrace() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo: The header name for the key exception stack trace.
getKeySerializer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getKeySerializer() - Method in interface org.springframework.kafka.core.ProducerFactory: Return the configured key serializer (if provided as an object instead of a class name in the properties).
getKeySerializerSupplier() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getKeySerializerSupplier() - Method in interface org.springframework.kafka.core.ProducerFactory: Return a supplier for a key serializer.
getListenerContainer(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry: Return the MessageListenerContainer with the specified id or null if no such container exists.
getListenerContainer(String) - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: 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).
getListenerContainerIds() - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return the ids of the managed MessageListenerContainer instance(s).
getListenerContainerRegistry() - Method in class org.springframework.kafka.listener.AbstractKafkaBackOffManagerFactory
getListenerContainers() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry: Return the managed MessageListenerContainer instance(s).
getListenerContainers() - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return the managed MessageListenerContainer instance(s).
getListenerContainersMatching(BiPredicate<String, MessageListenerContainer>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry: Return all MessageListenerContainer instances that satisfy the given bi-predicate.
getListenerContainersMatching(BiPredicate<String, MessageListenerContainer>) - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return all MessageListenerContainer instances that satisfy the given bi-predicate.
getListenerContainersMatching(Predicate<String>) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry: Return all MessageListenerContainer instances with id matching the predicate or empty Collection if no such container exists.
getListenerContainersMatching(Predicate<String>) - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return all MessageListenerContainer instances with id matching the predicate or empty Collection if no such container exists.
getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: The id of the listener (if @KafkaListener) or the container bean name.
getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent: The id of the listener (if @KafkaListener) or the container bean name.
getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent: The id of the listener (if @KafkaListener) or the container bean name.
getListenerId() - Method in class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent: The id of the listener (if @KafkaListener) or the container bean name.
getListenerId() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent: The id of the listener (if @KafkaListener) or the container bean name.
getListenerId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getListenerId() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getListenerId() - Method in class org.springframework.kafka.listener.KafkaConsumerBackoffManager.Context
getListenerId() - Method in interface org.springframework.kafka.listener.ListenerMetadata: Return the listener id.
getListenerId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: The 'id' attribute of a @KafkaListener or the bean name for spring-managed containers.
getListenerId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the listener id.
getListenerIds() - Method in class org.springframework.kafka.listener.ContainerGroup: Return the listener ids of the containers in this group.
getListenerInfo() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getListenerInfo() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Get the listener info to insert in the record header.
getListenerInfo() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getListenerInfo() - Method in interface org.springframework.kafka.listener.ListenerMetadata: Return the listener info.
getListenerInfo() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: Get arbitrary static information that will be added to the KafkaHeaders.LISTENER_INFO header of all records.
getListeners() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean: Get the current list of listeners.
getListeners() - Method in interface org.springframework.kafka.core.ConsumerFactory: Get the current list of listeners.
getListeners() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory: Get the current list of listeners.
getListeners() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory: Get the current list of listeners.
getListeners() - Method in interface org.springframework.kafka.core.ProducerFactory: Get the current list of listeners.
getListenerTaskExecutor() - Method in class org.springframework.kafka.listener.ContainerProperties: Return the consumer task executor.
getLogDir() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker.EmbeddedZookeeper
getLogLevel() - Method in class org.springframework.kafka.listener.KafkaExceptionLogLevelAware: Set the level at which the exception thrown by this handler is logged.
getLowCardinalityKeyValues(KafkaRecordReceiverContext) - Method in class org.springframework.kafka.support.micrometer.KafkaListenerObservation.DefaultKafkaListenerObservationConvention
getLowCardinalityKeyValues(KafkaRecordSenderContext) - Method in class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getMainListenerId() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getMainListenerId() - Method in interface org.springframework.kafka.config.KafkaListenerEndpoint: Return the main listener id if this container is for a retry topic.
getMainListenerId() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getMainListenerId() - Method in interface org.springframework.kafka.listener.MessageListenerContainer: The 'id' attribute of the main @KafkaListener container, if this container is for a retry topic; null otherwise.
getMaxAttempts(int) - Method in class org.springframework.kafka.retrytopic.BackOffValuesGenerator
getMaxRetries() - Method in class org.springframework.kafka.support.ExponentialBackOffWithMaxRetries: Get the max retries.
getMessage() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
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.annotation.KafkaListenerAnnotationBeanPostProcessor: Return the configured handler factory.
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.ContainerProperties
getMessagingConverter() - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter
getMethod() - Method in class org.springframework.kafka.config.MethodKafkaListenerEndpoint
getMethod() - Method in class org.springframework.kafka.support.EndpointHandlerMethod: Return the method.
getMethodAsString(Object) - Method in class org.springframework.kafka.listener.adapter.HandlerAdapter
getMethodName() - Method in class org.springframework.kafka.support.EndpointHandlerMethod: Return the method name.
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.
getMethods() - Method in class org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint: Get a method list.
getMethods() - Method in class org.springframework.kafka.support.EndpointHandlerMultiMethod: Return the method list.
getMicrometerTags() - Method in class org.springframework.kafka.listener.ContainerProperties: Return static Micrometer tags.
getMicrometerTagsProvider() - Method in class org.springframework.kafka.core.KafkaTemplate: Return the Micrometer tags provider.
getMicrometerTagsProvider() - Method in class org.springframework.kafka.listener.ContainerProperties: Return the Micrometer tags provider.
getMonitorInterval() - Method in class org.springframework.kafka.listener.ContainerProperties
getMsg() - Method in exception org.springframework.kafka.support.converter.ConversionException: Return the Message, if available.
getName() - Method in class org.springframework.kafka.listener.ContainerGroup: Return the group name.
getName() - Method in interface org.springframework.kafka.support.micrometer.KafkaListenerObservationConvention
getName() - Method in class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getName() - Method in interface org.springframework.kafka.support.micrometer.KafkaTemplateObservationConvention
getNextDestination() - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver.DestinationTopicHolder
getNextDestinationTopicFor(String, String) - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver
getNextDestinationTopicFor(String, String) - Method in interface org.springframework.kafka.retrytopic.DestinationTopicContainer: Returns the DestinationTopic instance registered as the next destination topic in the chain for the given topic.
getNonBlockingRetryDeliveryAttempt() - Method in class org.springframework.kafka.support.KafkaMessageHeaderAccessor: When using non-blocking retries, get the delivery attempt header value as an int.
getNoPollThreshold() - Method in class org.springframework.kafka.listener.ContainerProperties
getObjectMapper() - Method in class org.springframework.kafka.support.converter.JsonMessageConverter: Return the object mapper.
getObjectMapper() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Return the object mapper.
getObjectType() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
getObservationConvention() - Method in class org.springframework.kafka.listener.ContainerProperties
getOffset() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the offset.
getOffset() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getOffsetAndMetadataProvider() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the offset and metadata provider.
getOffsetComputeFunction() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getOffsetHeader() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the offset.
getOneRecord(String, String, String, int, boolean, boolean, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Get a single record for the group from the topic/partition.
getOperationTimeout() - Method in class org.springframework.kafka.core.KafkaAdmin: Return the operation timeout in seconds.
getOrder() - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor
getOrder() - Method in interface org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer
getOriginal() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames: The header names for the original record headers.
getParser() - Method in class org.springframework.kafka.support.serializer.ParseStringDeserializer: Get the configured parser function.
getPartition() - Method in class org.springframework.kafka.event.ConsumerPartitionPausedEvent: Return the paused partition.
getPartition() - Method in class org.springframework.kafka.event.ConsumerPartitionResumedEvent
getPartition() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the partition.
getPartition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getPartitionHeader() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the partition.
getPartitions() - Method in class org.springframework.kafka.event.ConsumerPartitionPausedEvent: Deprecated, for removal: This API element is subject to removal in a future version.
replaced by ConsumerPartitionPausedEvent.getPartition()
getPartitions() - Method in class org.springframework.kafka.event.ConsumerPausedEvent: Return the paused partitions.
getPartitions() - Method in class org.springframework.kafka.event.ConsumerResumedEvent
getPartitions() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent
getPartitionsPerTopic() - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker: Get the configured number of partitions per topic.
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getPhase() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
getPhase() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
getPhase() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getPhase() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getPhase() - Method in class org.springframework.kafka.listener.ContainerGroupSequencer
getPhase() - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
getPhysicalCloseTimeout() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory: Get the physical close timeout.
getPhysicalCloseTimeout() - Method in interface org.springframework.kafka.core.ProducerFactory: Get the physical close timeout.
getPollTimeout() - Method in class org.springframework.kafka.listener.ConsumerProperties
getPollTimeoutWhilePaused() - Method in class org.springframework.kafka.listener.ContainerProperties: The poll timeout to use while paused; usually a lower number than pollTimeout.
getPort() - Method in class org.springframework.kafka.test.core.BrokerAddress
getPort() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker.EmbeddedZookeeper
getPosition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getPostProcessors() - Method in interface org.springframework.kafka.core.ConsumerFactory: Get the current list of post processors.
getPostProcessors() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
getPostProcessors() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getPostProcessors() - Method in interface org.springframework.kafka.core.ProducerFactory: Get the current list of post processors.
getProducer() - Method in class org.springframework.kafka.core.KafkaResourceHolder
getProducerConfigs() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory: Return the configuration of a producer.
getProducerFactory() - Method in interface org.springframework.kafka.core.KafkaOperations: Return the producer factory used by this template.
getProducerFactory() - Method in class org.springframework.kafka.core.KafkaTemplate: Return the producer factory used by this template.
getProducerFactory() - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
getProducerFactory() - Method in class org.springframework.kafka.transaction.ChainedKafkaTransactionManager: Deprecated.
getProducerFactory() - Method in interface org.springframework.kafka.transaction.KafkaAwareTransactionManager: Get the producer factory.
getProducerFactory() - Method in class org.springframework.kafka.transaction.KafkaTransactionManager: Get the producer factory.
getProducerFactory(String) - Method in class org.springframework.kafka.core.KafkaTemplate: Return the producer factory used by this template based on the topic.
getProducerFactory(String) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate
getProducerRecord() - Method in class org.springframework.kafka.support.SendResult
getPropertyValue(Object, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.
getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: A typed version of KafkaTestUtils.getPropertyValue(Object, String).
getRawHeaders() - Method in class org.springframework.kafka.support.converter.KafkaMessageHeaders
getReason() - Method in class org.springframework.kafka.event.ConcurrentContainerStoppedEvent: Return the reason why the container was stopped.
getReason() - Method in class org.springframework.kafka.event.ConsumerRetryAuthEvent: Return the reason for the auth failure.
getReason() - Method in class org.springframework.kafka.event.ConsumerStoppedEvent: Return the reason why the consumer was stopped.
getRecord() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException: Return the failed record.
getRecord() - Method in class org.springframework.kafka.streams.HeaderEnricherProcessor.Container
getRecord() - Method in exception org.springframework.kafka.support.converter.ConversionException: Return the consumer record, if available.
getRecord() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the consumer record.
getRecord() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext: Return the producer record.
getRecordFilterStrategy() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRecordFilterStrategy() - Method in class org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener
getRecordInterceptor() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer
getRecordMessageConverter() - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter: Return the record converter used by this batch converter, if configured, or null.
getRecordMessageConverter() - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter
getRecordMetadata() - Method in class org.springframework.kafka.support.SendResult
getRecords() - Method in exception org.springframework.kafka.support.converter.ConversionException: Return the consumer record, if available.
getRecords(Consumer<K, V>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer for records.
getRecords(Consumer<K, V>, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer for records.
getRecords(Consumer<K, V>, Duration, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer for records.
getRecoveryCallback() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
getReplyHeadersConfigurer() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter: Return the reply configurer.
getReplyTemplate() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getResolver() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
getRetryListeners() - Method in class org.springframework.kafka.listener.FailedRecordProcessor
getRetrySuffix() - Method in class org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory.DestinationTopicSuffixes
getRetryTemplate() - Method in class org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter
getScheduler() - Method in class org.springframework.kafka.listener.ContainerProperties: Return the task scheduler, if present.
getScheduler() - Method in class org.springframework.kafka.retrytopic.RetryTopicSchedulerWrapper
getSeekCallbackFor(TopicPartition) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware: Deprecated, for removal: This API element is subject to removal in a future version.
Replaced by AbstractConsumerSeekAware.getSeekCallbacksFor(TopicPartition)
getSeekCallbacks() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware: Deprecated, for removal: This API element is subject to removal in a future version.
Replaced by AbstractConsumerSeekAware.getTopicsAndCallbacks()
getSeekCallbacksFor(TopicPartition) - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware: Return the callbacks for the specified topic/partition.
getSendFuture() - Method in class org.springframework.kafka.requestreply.RequestReplyFuture: Return the send future.
getSendFuture() - Method in class org.springframework.kafka.requestreply.RequestReplyMessageFuture: Return the send future.
getShutdownTimeout() - Method in class org.springframework.kafka.listener.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.
getSingleRecord(Consumer<K, V>, String, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils: Poll the consumer, expecting a single record for the specified topic.
getSnapshotDir() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker.EmbeddedZookeeper
getSource() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext: Return the source topic.
getSource(Class<T>) - Method in class org.springframework.kafka.event.KafkaEvent: Get the container (source) that published the event.
getSourceDestination() - Method in class org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver.DestinationTopicHolder
getStreamsConfiguration() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean
getStreamsUncaughtExceptionHandler() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean: Retrieves the current StreamsUncaughtExceptionHandler set on this factory bean.
getSubBatchPerPartition() - Method in class org.springframework.kafka.listener.ContainerProperties: Return whether to split batches by partition; null if not set.
getSyncCommitTimeout() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the sync commit timeout.
getTheProducer(String) - Method in class org.springframework.kafka.core.KafkaTemplate
getThreadNameSupplier() - Method in class org.springframework.kafka.listener.AbstractMessageListenerContainer: Return the function used to change the consumer thread name.
getTimeoutBuffer() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer: The number of milliseconds to add to the producer configuration delivery.timeout.ms property to avoid timing out before the Kafka producer.
getTimeSinceLastPoll() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent: How long since the last poll.
getTimestamp() - Method in exception org.springframework.kafka.listener.TimestampedException
getTimestampHeader() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the timestamp.
getTimestampTypeHeader() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the timestamp type.
getTopic() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo
getTopic() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getTopicHeader() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Original: The header name for the topic.
getTopicName(String) - Method in interface org.springframework.kafka.retrytopic.RetryTopicNamesProviderFactory.RetryTopicNamesProvider: Return the tropic name that will override the base topic name.
getTopicName(String) - Method in class org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getTopicPartition() - Method in class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent: The idle TopicPartition.
getTopicPartition() - Method in class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent: The idle TopicPartition.
getTopicPartition() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getTopicPartition() - Method in class org.springframework.kafka.listener.KafkaConsumerBackoffManager.Context
getTopicPartition() - Method in class org.springframework.kafka.support.TopicPartitionOffset
getTopicPartitions() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent: The TopicPartitions the container is listening to.
getTopicPartitions() - Method in class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent: The TopicPartitions the container is listening to.
getTopicPartitions() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent: The TopicPartitions the container is listening to.
getTopicPartitions() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the configured TopicPartitionOffsets.
getTopicPartitionsToAssign() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint: Return the topicPartitions for this endpoint.
getTopicPartitionsToAssign() - 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.
getTopicPattern() - Method in class org.springframework.kafka.listener.ConsumerProperties: Return the configured topic pattern.
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.ConsumerProperties: Return the configured topics.
getTopics() - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker: Get the topics.
getTopics() - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker
getTopics() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getTopicsAndCallbacks() - Method in class org.springframework.kafka.listener.AbstractConsumerSeekAware: The map of callbacks for all currently assigned partitions.
getTopology() - Method in class org.springframework.kafka.config.StreamsBuilderFactoryBean: Providing access to the associated Topology of this StreamsBuilderFactoryBean.
getToStringClasses() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Provide direct access to the toString() classes by subclasses.
getTransactionalResourceHolder(ProducerFactory<K, V>) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils: Obtain a Producer that is synchronized with the current transaction, if any.
getTransactionalResourceHolder(ProducerFactory<K, V>, String, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils: Obtain a Producer that is synchronized with the current transaction, if any.
getTransactionalResourceHolder(ProducerFactory<K, V>, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils: Obtain a Producer that is synchronized with the current transaction, if any.
getTransactionDefinition() - Method in class org.springframework.kafka.listener.ContainerProperties: Get the transaction definition.
getTransactionIdPrefix() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getTransactionIdPrefix() - Method in class org.springframework.kafka.core.KafkaTemplate
getTransactionIdPrefix() - Method in interface org.springframework.kafka.core.ProducerFactory: Return the transaction id prefix.
getTransactionManager() - Method in class org.springframework.kafka.listener.ContainerProperties: Deprecated, for removal: This API element is subject to removal in a future version.
getTrustedPackages() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper: Provide direct access to the trusted packages set for subclasses.
getTxIdPrefix() - Method in exception org.springframework.kafka.core.NoProducerAvailableException: Return the transaction id prefix that was used to create the producer and failed.
getTxProducerConfigs(String) - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory: Return the configuration of a transactional producer.
getType() - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter: Return the inferred type for conversion or, if null, the fallbackType.
getTypeMapper() - Method in class org.springframework.kafka.support.converter.JsonMessageConverter
getTypeMapper() - Method in class org.springframework.kafka.support.converter.MappingJacksonParameterizedConverter: Return the type mapper.
getTypeMapper() - Method in class org.springframework.kafka.support.serializer.JsonDeserializer
getTypeMapper() - Method in class org.springframework.kafka.support.serializer.JsonSerializer
getTypePrecedence() - Method in class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper: Return the precedence.
getTypePrecedence() - Method in interface org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper
getUnregisteredListenerContainer(String) - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistry
getUnregisteredListenerContainer(String) - Method in interface org.springframework.kafka.listener.ListenerContainerRegistry: Return the MessageListenerContainer with the specified id or null if no such container exists.
getUntrustedType() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType
getValidator() - Method in class org.springframework.kafka.config.KafkaListenerEndpointRegistrar: Get the validator, if supplied.
getValue() - Method in class org.springframework.kafka.streams.HeaderEnricherProcessor.Container
getValueDeserializer() - Method in interface org.springframework.kafka.core.ConsumerFactory: Return the configured value deserializer (if provided as an object instead of a class name in the properties).
getValueDeserializer() - Method in class org.springframework.kafka.core.DefaultKafkaConsumerFactory
getValueSerializer() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getValueSerializer() - Method in interface org.springframework.kafka.core.ProducerFactory: Return the configured value serializer (if provided as an object instead of a class name in the properties).
getValueSerializerSupplier() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory
getValueSerializerSupplier() - Method in interface org.springframework.kafka.core.ProducerFactory: Return a supplier for a value serializer.
getZkPort() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: Get the port that the embedded Zookeeper is running on or will run on.
getZookeeper() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getZooKeeperClient() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: Return the ZooKeeperClient.
getZookeeperConnectionString() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
GlobalEmbeddedKafkaTestExecutionListener - Class in org.springframework.kafka.test.junit: The TestExecutionListener to start an EmbeddedKafkaBroker in the beginning of the test plan and stop in the end.
GlobalEmbeddedKafkaTestExecutionListener() - Constructor for class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener
GROUP - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd: The consumer group that received the failed record.
GROUP_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders: For inbound messages, the container's group.id consumer property.
groupId() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener: Override the group.id property for the consumer factory with this value for this listener only.

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form