インターフェース KafkaProducerMessageHandler.ProducerRecordCreator<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
含まれているクラス:
KafkaProducerMessageHandler<K,V>
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public static interface KafkaProducerMessageHandler.ProducerRecordCreator<K,V>
Message および / または構成やメッセージから派生したプロパティから ProducerRecord を作成します。
導入:
5.4
作成者:
Soby Chacko, Artem Bilan, Gary Russell, Marius Bogoevici, Biju Kunjummen, Tom van den Berge, Ryan Riley, Jooyoung Pyoung

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    org.apache.kafka.clients.producer.ProducerRecord<K,V>
    create(Message<?> message, @Nullable StringSE topic, @Nullable IntegerSE partition, @Nullable LongSE timestamp, @Nullable K key, @Nullable V value, org.apache.kafka.common.header.Headers headers)
    レコードを作成します。

  • メソッドの詳細

    • create

      org.apache.kafka.clients.producer.ProducerRecord<K,V> create(Message<?> message, @Nullable StringSE topic, @Nullable IntegerSE partition, @Nullable LongSE timestamp, @Nullable K key, @Nullable V value, org.apache.kafka.common.header.Headers headers)
      レコードを作成します。
      パラメーター:
      message - 送信メッセージ。
      topic - トピック。
      partition - パーティション。
      timestamp - タイムスタンプ。
      key - キー。
      value - 値。
      headers - ヘッダー。
      戻り値:
      レコード。