パッケージ 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 です。
      戻り値:
      スペック。