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

フィールド概要