インターフェース RecordMessageConverter

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

  • 方法の概要

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

    インターフェース MessageConverter から継承されたメソッド

    commonHeaders

  • 方法の詳細

    • toMessage

      @NonNull Message<?> toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable ObjectSE acknowledgment, @Nullable ObjectSE consumer, @Nullable TypeSE payloadType)
      ConsumerRecord を Message に変換します。
      パラメーター:
      record - レコード。
      acknowledgment - 確認応答（Acknowledgment または ShareAcknowledgment のいずれか）。
      consumer - コンシューマー（Consumer または ShareConsumer のいずれか）。
      payloadType - 必要なペイロード型。
      戻り値:
      メッセージ。

    • fromMessage

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