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

インターフェース RecordMessageConverter

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

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    org.apache.kafka.clients.producer.ProducerRecord<?,?>
    fromMessage(Message<?> message, StringSE defaultTopic)
    メッセージをプロデューサーレコードに変換します。
    Message<?>
    toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, TypeSE payloadType)
    ConsumerRecord を Message に変換します。

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

    commonHeaders

  • メソッドの詳細

    • toMessage

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

    • fromMessage

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