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

A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.

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