パッケージ org.springframework.integration.debezium.dsl

クラス DebeziumMessageProducerSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<S,P>
org.springframework.integration.dsl.MessageProducerSpec<DebeziumMessageProducerSpec,DebeziumMessageProducer>
org.springframework.integration.debezium.dsl.DebeziumMessageProducerSpec
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<DebeziumMessageProducer>、InitializingBean、Lifecycle、Phased、SmartLifecycle
public class DebeziumMessageProducerSpec extends MessageProducerSpec<DebeziumMessageProducerSpec,DebeziumMessageProducer>
DebeziumMessageProducer の MessageProducerSpec。
導入:
6.2
作成者:
Christian Tzolov, Artem Bilan

  • コンストラクターの詳細

    • DebeziumMessageProducerSpec

      protected DebeziumMessageProducerSpec(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)

  • メソッドの詳細

    • enableBatch

      public DebeziumMessageProducerSpec enableBatch(boolean enable)
      ChangeEvent バッチモード処理を有効にします。有効にすると、チャネルアダプターは ChangeEvent の ListSE を単一のダウンストリーム Message のペイロードとして送信します。このようなバッチペイロードは直列化できません。デフォルトでは、バッチモードは無効になっています。すべての入力 ChangeEvent は、単一のダウンストリーム Message に変換されます。
      パラメーター:
      enable - バッチモードを有効にするには true に設定します。デフォルトでは無効になっています。
      戻り値:
      スペック。

    • enableEmptyPayload

      public DebeziumMessageProducerSpec enableEmptyPayload(boolean enabled)
      tombstone (別名削除) メッセージのサポートを有効にします。データベース行の削除時に、Debezium は、削除された行と同じキーと Optional.empty() の値を持つ tombstone 変更イベントを送信できます。このレコードは、ダウンストリームプロセッサーのマーカーです。これは、ログ圧縮により、このキーを持つすべてのレコードを削除できることを示します。Debezium コネクター構成で tombstone 機能が有効になっている場合は、空のペイロードも有効にする必要があります。
      パラメーター:
      enabled - 空のペイロードを有効にするには true を設定します。デフォルトでは無効になっています。
      戻り値:
      スペック。

    • taskExecutor

      public DebeziumMessageProducerSpec taskExecutor(TaskExecutor taskExecutor)
      Debezium エンジンには TaskExecutor を設定。
      パラメーター:
      taskExecutor - 使用する TaskExecutor。
      戻り値:
      スペック。

    • contentType

      public DebeziumMessageProducerSpec contentType(StringSE contentType)
      送信メッセージのコンテンツ型を設定します。提供された DebeziumEngine で使用される SerializationFormat 構成と一致する必要があります。
      パラメーター:
      contentType - ペイロードのコンテンツ型。
      戻り値:
      スペック。

    • headerNames

      public DebeziumMessageProducerSpec headerNames(StringSE... headerNames)
      送信メッセージヘッダーにマップされる ChangeEvent ヘッダー名のカンマ区切りのリスト。Debezium の NewRecordStateExtraction 'add.headers' プロパティは、ChangeEvent ヘッダーとして使用されるメタデータを構成します。

      "headerNames" に渡される名前には、Debezium の "add.headers.prefix" プロパティで構成された接頭辞を付ける必要があります。以降のデフォルトは "__" になります。たとえば、"add.headers=op,name" と "add.headers.prefix=__" の場合は、"__op"、"__name" のようなヘッダーを使用する必要があります。

      パラメーター:
      headerNames - このリストの値は、ヘッダー名と照合する単純なパターンにすることができます。
      戻り値:
      スペック。

    • headerMapper

      public DebeziumMessageProducerSpec headerMapper(HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>> headerMapper)
      ChangeEvent ヘッダーを Message ヘッダーに変換するには、HeaderMapper を設定します。
      パラメーター:
      headerMapper - 使用する HeaderMapper 実装。デフォルトは DefaultDebeziumHeaderMapper です。
      戻り値:
      スペック。