Index

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

H

handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - Method in class org.springframework.kafka.listener.FailedBatchProcessor
 
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
 
handleException(Object, Acknowledgment, Consumer<?, ?>, Message<?>, ListenerExecutionFailedException) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter
 
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.seeksAfterHandling() 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
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.
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.seeksAfterHandling() 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, Acknowledgment, Consumer<?, ?>, Message<?>) - 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.InvocationResult
Returns a hash code value for this object.
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 with CreateTime.
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
 
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.
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