インターフェース 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 に変換します。

    インターフェース org.springframework.kafka.support.converter.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 - the acknowledgment (can be Acknowledgment or ShareAcknowledgment).
      consumer - the consumer (can be Consumer or ShareConsumer).
      payloadType - 必要なペイロード型。
      戻り値:
      メッセージ。

    • fromMessage

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