Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
H
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ContainerAwareErrorHandler
-
Deprecated.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
-
Deprecated.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ContainerAwareErrorHandler
-
Deprecated.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecord<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.BatchErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler
-
Deprecated.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.BatchErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.ContainerAwareBatchErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.FailedBatchProcessor
- handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.ListenerInvokingBatchErrorHandler
-
Deprecated.
- handle(Exception, T) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Deprecated.Handle the exception.
- handle(Exception, T, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.GenericErrorHandler
-
Deprecated.Handle the exception.
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - Method in class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.CommonContainerStoppingErrorHandler
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.CommonDelegatingErrorHandler
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Handle the exception for a batch listener.
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.CommonLoggingErrorHandler
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
- handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.DefaultErrorHandler
- handleBatchAndReturnRemaining(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Handle the exception for a batch listener.
- handleBatchAndReturnRemaining(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.DefaultErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.kafka.listener.ConsumerAwareListenerErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.kafka.listener.KafkaListenerErrorHandler
-
Handle the error.
- handleError(Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.kafka.listener.ManualAckListenerErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.ConsumerAwareListenerErrorHandler
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - Method in interface org.springframework.kafka.listener.KafkaListenerErrorHandler
-
Handle the error.
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>, Acknowledgment) - Method in interface org.springframework.kafka.listener.KafkaListenerErrorHandler
-
Handle the error.
- handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>, Acknowledgment) - Method in interface org.springframework.kafka.listener.ManualAckListenerErrorHandler
- handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonDelegatingErrorHandler
- handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Handle the exception for a record listener when
CommonErrorHandler.remainingRecords()
returns false. - handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonLoggingErrorHandler
- handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
- handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.DefaultErrorHandler
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in class org.springframework.kafka.listener.CommonContainerStoppingErrorHandler
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in class org.springframework.kafka.listener.CommonDelegatingErrorHandler
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Called when an exception is thrown with no records available, e.g.
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in class org.springframework.kafka.listener.CommonLoggingErrorHandler
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
- handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - Method in class org.springframework.kafka.listener.DefaultErrorHandler
- HandlerAdapter - Class in org.springframework.kafka.listener.adapter
-
A wrapper for either an
InvocableHandlerMethod
orDelegatingInvocableHandler
. - HandlerAdapter(DelegatingInvocableHandler) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter
-
Construct an instance with the provided delegating handler.
- HandlerAdapter(InvocableHandlerMethod) - Constructor for class org.springframework.kafka.listener.adapter.HandlerAdapter
-
Construct an instance with the provided method.
- handleRecord(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Deprecated, for removal: This API element is subject to removal in a future version.
- handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonContainerStoppingErrorHandler
- handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonDelegatingErrorHandler
- handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in interface org.springframework.kafka.listener.CommonErrorHandler
-
Handle the exception for a record listener when
CommonErrorHandler.remainingRecords()
returns true. - handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.CommonMixedErrorHandler
- handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - Method in class org.springframework.kafka.listener.DefaultErrorHandler
- handleResult(Object, Object, Object) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
-
Handle the given result object returned from the listener method, sending a response message to the SendTo topic.
- handleTimeout(Object, RequestReplyFuture<K, V, Collection<ConsumerRecord<K, R>>>) - Method in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate
- handleTimeout(Object, RequestReplyFuture<K, V, R>) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate
-
Used to inform subclasses that a request has timed out so they can clean up state and, optionally, complete the future.
- hasConfigurationForTopics(String[]) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfiguration
- hasDefaultHandler() - Method in class org.springframework.kafka.listener.adapter.DelegatingInvocableHandler
- hashCode() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hashCode() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot
-
Returns a hash code value for this object.
- hashCode() - Method in class org.springframework.kafka.requestreply.CorrelationKey
- hashCode() - Method in class org.springframework.kafka.retrytopic.DestinationTopic
- hashCode() - Method in class org.springframework.kafka.retrytopic.DestinationTopic.Properties
- hashCode() - Method in class org.springframework.kafka.support.TopicPartitionOffset
- hashCode() - Method in class org.springframework.kafka.test.core.BrokerAddress
- hasKey(K) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- hasNoRestrictions() - Method in class org.springframework.kafka.support.AllowDenyCollectionManager
- hasOffset() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hasPartition(int) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- hasTimestamp() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
- hasTimestamp(long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
-
Matcher testing the timestamp of a
ConsumerRecord
assuming the topic has been set withCreateTime
. - hasTimestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
-
Matcher testing the timestamp of a
ConsumerRecord
- hasValue(V) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
- HeaderEnricher<K,
V> - Class in org.springframework.kafka.streams -
Deprecated.in favor of
HeaderEnricherProcessor
. - HeaderEnricher(Map<String, Expression>) - Constructor for class org.springframework.kafka.streams.HeaderEnricher
-
Deprecated.
- HeaderEnricher.Container<K,
V> - Class in org.springframework.kafka.streams -
Deprecated.Container object for SpEL evaluation.
- HeaderEnricherProcessor<K,
V> - Class in org.springframework.kafka.streams -
Manipulate the headers.
- HeaderEnricherProcessor(Map<String, Expression>) - Constructor for class org.springframework.kafka.streams.HeaderEnricherProcessor
-
Construct an instance with the provided header expressions.
- HeaderEnricherProcessor.Container<K,
V> - Class in org.springframework.kafka.streams -
Container object for SpEL evaluation.
- headerValueToAddIn(Header) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Check if the header value should be mapped to a String, if so configured.
- headerValueToAddOut(String, Object) - Method in class org.springframework.kafka.support.AbstractKafkaHeaderMapper
-
Check if the value is a String and convert to byte[], if so configured.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
CommonErrorHandler.handleOne(Exception, ConsumerRecord, Consumer, MessageListenerContainer)
.