インデックス

H

handle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - クラス org.springframework.kafka.streams のメソッド。RecoveringDeserializationExceptionHandler

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。CommonContainerStoppingErrorHandler

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

バッチリスナーの例外を処理します。

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。CommonLoggingErrorHandler

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

handleBatch(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

handleBatchAndReturnRemaining(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

バッチリスナーの例外を処理します。

handleBatchAndReturnRemaining(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

handleError(Message<?>, ListenerExecutionFailedException) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareListenerErrorHandler

handleError(Message<?>, ListenerExecutionFailedException) - インターフェース org.springframework.kafka.listener のメソッド。KafkaListenerErrorHandler

エラーを処理します。

handleError(Message<?>, ListenerExecutionFailedException) - インターフェース org.springframework.kafka.listener のメソッド。ManualAckListenerErrorHandler

handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareListenerErrorHandler

handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。KafkaListenerErrorHandler

エラーを処理します。

handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>, Acknowledgment) - インターフェース org.springframework.kafka.listener のメソッド。KafkaListenerErrorHandler

エラーを処理します。

handleError(Message<?>, ListenerExecutionFailedException, Consumer<?, ?>, Acknowledgment) - インターフェース org.springframework.kafka.listener のメソッド。ManualAckListenerErrorHandler

handleException(Object, Acknowledgment, Consumer<?, ?>, Message<?>, ListenerExecutionFailedException) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

CommonErrorHandler.seeksAfterHandling() が false を返したときに、レコードリスナーの例外を処理します。

handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonLoggingErrorHandler

handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

handleOne(Exception, ConsumerRecord<?, ?>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - クラス org.springframework.kafka.listener のメソッド。CommonContainerStoppingErrorHandler

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

利用可能なレコードがない状態で例外がスローされた場合に呼び出されます。

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - クラス org.springframework.kafka.listener のメソッド。CommonLoggingErrorHandler

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

handleOtherException(Exception, Consumer<?, ?>, MessageListenerContainer, boolean) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

HandlerAdapter - org.springframework.kafka.listener.adapter のクラス

InvocableHandlerMethod または DelegatingInvocableHandler のラッパー。

HandlerAdapter(DelegatingInvocableHandler) - クラス org.springframework.kafka.listener.adapter. HandlerAdapter のコンストラクター

提供されている委譲ハンドラーを使用してインスタンスを構築します。

HandlerAdapter(InvocableHandlerMethod) - クラス org.springframework.kafka.listener.adapter. HandlerAdapter のコンストラクター

提供されたメソッドを使用してインスタンスを構築します。

handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonContainerStoppingErrorHandler

handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

CommonErrorHandler.seeksAfterHandling() が true を返したときに、レコードリスナーの例外を処理します。

handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

handleRemaining(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

handleResult(Object, Object, Acknowledgment, Consumer<?, ?>, Message<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

リスナーメソッドから返された指定された結果オブジェクトを処理し、SendTo トピックにレスポンスメッセージを送信します。

handleTimeout(Object, RequestReplyFuture<K, V, Collection<ConsumerRecord<K, R>>>) - クラス org.springframework.kafka.requestreply のメソッド。AggregatingReplyingKafkaTemplate

handleTimeout(Object, RequestReplyFuture<K, V, R>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

リクエストがタイムアウトしたことをサブクラスに通知して、状態をクリーンアップし、オプションでフューチャーを完了することができるようにするために使用されます。

hasConfigurationForTopics(String[]) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfiguration

hasDefaultHandler() - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler

hashCode() - クラス org.springframework.kafka.listener.adapter のメソッド。ConsumerRecordMetadata

hashCode() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

このオブジェクトのハッシュコード値を返します。

hashCode() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

このオブジェクトのハッシュコード値を返します。

hashCode() - クラス org.springframework.kafka.requestreply のメソッド。CorrelationKey

hashCode() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic

hashCode() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic.Properties

hashCode() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset

hashCode() - クラス org.springframework.kafka.test.core のメソッド。BrokerAddress

hasKey(K) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

hasNoRestrictions() - クラス org.springframework.kafka.support のメソッド。AllowDenyCollectionManager

hasOffset() - クラス org.springframework.kafka.listener.adapter のメソッド。ConsumerRecordMetadata

hasPartition(int) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

hasTimestamp() - クラス org.springframework.kafka.listener.adapter のメソッド。ConsumerRecordMetadata

hasTimestamp(long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

トピックが CreateTime で設定されていると仮定して、ConsumerRecord のタイムスタンプをテストするマッチャー。

hasTimestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

ConsumerRecord のタイムスタンプをテストするマッチャー

hasValue(V) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers

HeaderEnricherProcessor< K , V > - Class in org.springframework.kafka.streams

ヘッダーを操作します。

HeaderEnricherProcessor(Map<String, Expression>) - クラス org.springframework.kafka.streams. HeaderEnricherProcessor のコンストラクター

提供されたヘッダー式でインスタンスを構築します。

HeaderEnricherProcessor.Container < K、V > - org.springframework.kafka.streams のクラス

SpEL 評価用のコンテナーオブジェクト。

headerValueToAddIn(Header) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

構成されている場合、ヘッダー値を文字列にマップする必要があるかどうかを確認します。

headerValueToAddOut(String, Object) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

値が文字列であるかどうかを確認し、構成されている場合は byte[] に変換します。