org.springframework.integration.kafka.inbound.KafkaErrorSendingMessageRecoverer

実装されたすべてのインターフェース:: BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE>、Aware、BeanFactoryAware、org.springframework.kafka.listener.ConsumerRecordRecoverer

public class KafkaErrorSendingMessageRecoverer extends ErrorMessagePublisher implements org.springframework.kafka.listener.ConsumerRecordRecoverer

Kafka 配信障害を回復するために CommonErrorHandler で使用できる ErrorMessagePublisher の拡張。

フィールドのサマリー
クラス org.springframework.integration.core.ErrorMessagePublisher から継承されたフィールド
logger, messagingTemplate
コンストラクターの概要
コンストラクター
コンストラクター
説明
KafkaErrorSendingMessageRecoverer(MessageChannel channel)
RawRecordHeaderErrorMessageStrategy でチャネルに送信するインスタンスを構築します。
KafkaErrorSendingMessageRecoverer(MessageChannel channel, ErrorMessageStrategy errorMessageStrategy)
エラーメッセージ戦略を使用して、チャネルを送信するインスタンスを構築します。
メソッドのサマリー
修飾子と型
メソッド
説明
void
accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE ex)
クラス org.springframework.integration.core.ErrorMessagePublisher から継承されたメソッド
determinePayload, getChannel, getChannelResolver, getErrorMessageStrategy, getMessagingTemplate, payloadWhenNull, publish, publish, publish, publish, publish, setBeanFactory, setChannel, setChannelName, setChannelResolver, setErrorMessageStrategy, setSendTimeout
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース java.util.function.BiConsumerSE から継承されたメソッド
andThenSE

コンストラクターの詳細
- KafkaErrorSendingMessageRecoverer
  public KafkaErrorSendingMessageRecoverer(MessageChannel channel)
  RawRecordHeaderErrorMessageStrategy でチャネルに送信するインスタンスを構築します。
  パラメーター:
  channel - チャンネル。
- KafkaErrorSendingMessageRecoverer
  public KafkaErrorSendingMessageRecoverer(MessageChannel channel, ErrorMessageStrategy errorMessageStrategy)
  エラーメッセージ戦略を使用して、チャネルを送信するインスタンスを構築します。
  パラメーター:
  channel - チャンネル。
  errorMessageStrategy - 戦略。
メソッドの詳細
- accept
  public void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ExceptionSE ex)
  次で指定:
  インターフェース BiConsumerSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE> の acceptSE

クラス KafkaErrorSendingMessageRecoverer

フィールドのサマリー