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

インターフェース BatchMessageConverter

すべてのスーパーインターフェース:
MessageConverter
すべての既知の実装クラス:
BatchMessagingMessageConverter
public interface BatchMessageConverter extends MessageConverter
Kafka 固有の Message コンバーター戦略。
導入:
1.1
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    ListSE<org.apache.kafka.clients.producer.ProducerRecord<?,?>>
    fromMessage(Message<?> message, StringSE defaultTopic)
    メッセージをプロデューサーレコードに変換します。
    default RecordMessageConverter
    getRecordMessageConverter()
    このバッチコンバーターが使用するレコードコンバーター (構成されている場合) または null を返します。
    Message<?>
    toMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, TypeSE payloadType)
    ConsumerRecord のリストを Message に変換します。

    インターフェース org.springframework.kafka.support.converter.MessageConverter から継承されたメソッド

    commonHeaders

  • メソッドの詳細

    • toMessage

      @NonNull Message<?> toMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, TypeSE payloadType)
      ConsumerRecord のリストを Message に変換します。
      パラメーター:
      records - 記録。
      acknowledgment - 承認。
      consumer - コンシューマー。
      payloadType - 必要なペイロード型。
      戻り値:
      メッセージ。

    • fromMessage

      ListSE<org.apache.kafka.clients.producer.ProducerRecord<?,?>> fromMessage(Message<?> message, StringSE defaultTopic)
      メッセージをプロデューサーレコードに変換します。
      パラメーター:
      message - メッセージ。
      defaultTopic - ヘッダーが見つからない場合に使用するデフォルトのトピック。
      戻り値:
      プロデューサーの記録。

    • getRecordMessageConverter

      @Nullable default RecordMessageConverter getRecordMessageConverter()
      このバッチコンバーターが使用するレコードコンバーター (構成されている場合) または null を返します。
      戻り値:
      コンバーターまたは null。
      導入:
      2.1.5