パッケージ org.springframework.kafka.support.converter

インターフェース MessageConverter

すべての既知のサブインターフェース:
BatchMessageConverter, RecordMessageConverter
すべての既知の実装クラス:
BatchMessagingMessageConverter、ByteArrayJsonMessageConverter、BytesJsonMessageConverter、JsonMessageConverter、MessagingMessageConverter、ProjectingMessageConverter、StringJsonMessageConverter
public interface MessageConverter
メッセージコンバーターのトップレベルのインターフェース。
導入:
1.1
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    commonHeaders(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MapSE<StringSE,ObjectSE> rawHeaders, ObjectSE theKey, ObjectSE topic, ObjectSE partition, ObjectSE offset, ObjectSE timestampType, ObjectSE timestamp)
    共通ヘッダーを設定します。
    static StringSE
    getGroupId()
    スレッドにバインドされたグループ ID を取得します。

  • メソッドの詳細

    • getGroupId

      @Nullable static StringSE getGroupId()
      スレッドにバインドされたグループ ID を取得します。
      戻り値:
      グループ ID。

    • commonHeaders

      default void commonHeaders(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MapSE<StringSE,ObjectSE> rawHeaders, @Nullable ObjectSE theKey, ObjectSE topic, ObjectSE partition, ObjectSE offset, @Nullable ObjectSE timestampType, ObjectSE timestamp)
      共通ヘッダーを設定します。
      パラメーター:
      acknowledgment - 承認。
      consumer - コンシューマー。
      rawHeaders - 生のヘッダーマップ。
      theKey - キー。
      topic - トピック。
      partition - パーティション。
      offset - オフセット。
      timestampType - タイムスタンプ型。
      timestamp - タイムスタンプ。