クラス ConversionException

実装されたすべてのインターフェース:
SerializableSE

public class ConversionException extends KafkaException
変換の例外。
作成者:
Gary Russell
関連事項:
  • コンストラクターの詳細

    • ConversionException

      public ConversionException(StringSE message, ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - 理由を説明するテキストメッセージ。
      cause - 原因。
    • ConversionException

      public ConversionException(StringSE message, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - 理由を説明するテキストメッセージ。
      record - コンシューマー記録。
      cause - 原因。
      導入:
      2.7.2
    • ConversionException

      public ConversionException(StringSE message, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - 理由を説明するテキストメッセージ。
      records - コンシューマーの記録。
      cause - 原因。
      導入:
      2.7.2
    • ConversionException

      public ConversionException(StringSE message, Message<?> msg, ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - 理由を説明するテキストメッセージ。
      msg - コンシューマーレコードから変換された Message
      cause - 原因。
      導入:
      2.7.2
  • メソッドの詳細

    • getRecord

      @Nullable public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()
      可能な場合は、コンシューマーレコードを返します。
      戻り値:
      レコード。
      導入:
      2.7.2
    • getRecords

      public ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> getRecords()
      可能な場合は、コンシューマーレコードを返します。
      戻り値:
      レコード。
      導入:
      2.7.2
    • getMsg

      @Nullable public Message<?> getMsg()
      可能であれば、Message を返します。
      戻り値:
      メッセージ。
      導入:
      2.7.2