クラス DebeziumMessageProducer

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.debezium.inbound.DebeziumMessageProducer
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、MessageProducer、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class DebeziumMessageProducer extends MessageProducerSupport
Debezium イベントチャネルアダプターを変更します。
導入:
6.2
作成者:
Christian Tzolov, Artem Bilan

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

    • DebeziumMessageProducer

      public DebeziumMessageProducer(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumBuilder)
      新しい Debezium メッセージプロデューサー受信 チャネルアダプターを作成します。
      パラメーター:
      debeziumBuilder - - 事前設定された Debezium Engine Builder インスタンス。

  • メソッドの詳細

    • setEnableBatch

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

    • setEnableEmptyPayload

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

    • setTaskExecutor

      public void setTaskExecutor(TaskExecutor taskExecutor)
      Debezium エンジンタスクに TaskExecutor を設定します。
      パラメーター:
      taskExecutor - 使用する TaskExecutor。

    • setContentType

      public void setContentType(StringSE contentType)
      送信メッセージのコンテンツ型を設定します。提供された DebeziumEngine で使用される SerializationFormat 構成と一致する必要があります。

    • setHeaderMapper

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

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス IntegrationObjectSupport の getComponentType 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス MessageProducerSupport の onInit 

    • doStart

      protected void doStart()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
      オーバーライド:
      クラス MessageProducerSupport の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス MessageProducerSupport の doStop