クラス KafkaException

java.lang.ObjectSE
java.lang.ThrowableSE
java.lang.ExceptionSE
java.lang.RuntimeExceptionSE
org.springframework.core.NestedRuntimeException
org.springframework.kafka.KafkaException
実装されているすべてのインターフェース:
SerializableSE
既知の直属サブクラス
BatchListenerFailedException、ConversionException、DeserializationException、KafkaBackoffException、KafkaProducerException、KafkaReplyTimeoutException、ListenerExecutionFailedException、NoProducerAvailableException、TimestampedException
public class KafkaException extends NestedRuntimeException
Spring for Apache Kafka 固有の NestedRuntimeException 実装。
作成者:
Gary Russell, Artem Bilan
関連事項:

  • コンストラクターの詳細

    • KafkaException

      public KafkaException(StringSE message)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - メッセージ。

    • KafkaException

      public KafkaException(StringSE message, @Nullable ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - メッセージ。
      cause - 原因。

    • KafkaException

      public KafkaException(StringSE message, KafkaException.Level level, @Nullable ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - メッセージ。
      level - selfLog(String, LogAccessor) の使用時にこの例外がログに記録されるレベル。
      cause - 原因。

  • メソッドの詳細

    • selfLog

      public void selfLog(StringSE message, LogAccessor logger)
      この例外をログレベルで記録します。
      パラメーター:
      message - メッセージ。
      logger - ログアクセサー。