クラス KafkaUtils

java.lang.ObjectSE
org.springframework.kafka.support.KafkaUtils
public final class KafkaUtils extends ObjectSE
ユーティリティメソッド。
導入:
2.2
作成者:
Gary Russell, Wang ZhiYang, Soby Chacko

  • フィールドの詳細

    • DESERIALIZER_EXCEPTION_HEADER_PREFIX

      public static final StringSE DESERIALIZER_EXCEPTION_HEADER_PREFIX
      デシリアライズ例外のヘッダー名。
      導入:
      3.0.15
      関連事項:

    • KEY_DESERIALIZER_EXCEPTION_HEADER

      public static final StringSE KEY_DESERIALIZER_EXCEPTION_HEADER
      デシリアライズ例外のヘッダー名。
      導入:
      3.0.15
      関連事項:

    • VALUE_DESERIALIZER_EXCEPTION_HEADER

      public static final StringSE VALUE_DESERIALIZER_EXCEPTION_HEADER
      デシリアライズ例外のヘッダー名。
      導入:
      3.0.15
      関連事項:

    • MICROMETER_PRESENT

      public static final boolean MICROMETER_PRESENT
      micrometer がクラスパス上にある場合は True。

  • メソッドの詳細

    • returnTypeMessageOrCollectionOf

      public static boolean returnTypeMessageOrCollectionOf(MethodSE method)
      メソッドの戻り値の型が Message または Collection<Message<?>> の場合は true を返します。
      パラメーター:
      method - メソッド。
      戻り値:
      メッセージを返す場合は true。

    • setConsumerGroupId

      public static void setConsumerGroupId(@Nullable StringSE groupId)
      このスレッドにバインドされているコンシューマーのグループ ID を設定します。
      パラメーター:
      groupId - グループ ID。
      導入:
      2.3

    • getConsumerGroupId

      public static @Nullable StringSE getConsumerGroupId()
      このスレッドにバインドされているコンシューマーのグループ ID を取得します。
      戻り値:
      グループ ID。
      導入:
      2.3

    • clearConsumerGroupId

      public static void clearConsumerGroupId()
      このスレッドにバインドされているコンシューマーのグループ ID をクリアします。
      導入:
      2.3

    • determineSendTimeout

      public static DurationSE determineSendTimeout(MapSE<StringSE,ObjectSE> producerProps, long buffer, long min)
      レコードを送信するときに使用するタイムアウトを返します。ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG が構成されていない場合、または long として解析できる数値または文字列でない場合は、ProducerConfig のデフォルト値（およびバッファー）が使用されます。
      パラメーター:
      producerProps - プロデューサーのプロパティ。
      buffer - Kafka プロデューサーの前にタイムアウトするのを防ぐために構成済みの ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG に追加するバッファー。
      min - 構成されたタイムアウトにバッファーを追加した後に適用する最小値。
      戻り値:
      使用するタイムアウト。
      導入:
      2.7

    • setConsumerRecordFormatter

      public static void setConsumerRecordFormatter(FunctionSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, StringSE> formatter)
      ConsumerRecord をログに記録するためのフォーマッターを設定します。
      パラメーター:
      formatter - レコードを文字列としてフォーマットする関数
      導入:
      2.7.12

    • setProducerRecordFormatter

      public static void setProducerRecordFormatter(FunctionSE<org.apache.kafka.clients.producer.ProducerRecord<?,?>, StringSE> formatter)
      ProducerRecord をログに記録するためのフォーマッターを設定します。
      パラメーター:
      formatter - レコードを文字列としてフォーマットする関数
      導入:
      2.7.12

    • format

      public static StringSE format(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
      ロギング用に ConsumerRecord をフォーマットします。デフォルトの topic-partition@offset。
      パラメーター:
      record - フォーマットするレコード。
      戻り値:
      フォーマットされた文字列。
      導入:
      2.7.12

    • format

      public static StringSE format(org.apache.kafka.clients.producer.ProducerRecord<?,?> record)
      ロギング用に ProducerRecord をフォーマットします。デフォルトは ProducerRecordObject.toString() です。
      パラメーター:
      record - フォーマットするレコード。
      戻り値:
      フォーマットされた文字列。
      導入:
      2.7.12