クラス Debezium

java.lang.ObjectSE
org.springframework.integration.debezium.dsl.Debezium
public final class Debezium extends ObjectSE
Debezium DSL コンポーネントのファクトリクラス。
導入:
6.2
作成者:
Christian Tzolov, Artem Bilan

  • メソッドの詳細

    • inboundChannelAdapter

      public static DebeziumMessageProducerSpec inboundChannelAdapter(PropertiesSE debeziumConfig)
      提供されたネイティブ debezium PropertiesSE および JSON 直列化形式用の DebeziumMessageProducerSpec のインスタンスを作成します。
      パラメーター:
      debeziumConfig - 必要な debezium エンジンとコネクターのプロパティを備えた PropertiesSE。
      戻り値:
      スペック。

    • inboundChannelAdapter

      public static DebeziumMessageProducerSpec inboundChannelAdapter(PropertiesSE debeziumConfig, ClassSE<? extends io.debezium.engine.format.SerializationFormat<byte[]>> messageFormat, ClassSE<? extends io.debezium.engine.format.SerializationFormat<byte[]>> headerFormat)
      提供されたネイティブ debezium PropertiesSE および直列化形式用の DebeziumMessageProducerSpec のインスタンスを作成します。
      パラメーター:
      debeziumConfig - 必要な debezium エンジンとコネクターのプロパティを備えた PropertiesSE。
      messageFormat - ChangeEvent キーとペイロードの SerializationFormat 形式。
      headerFormat - ChangeEvent ヘッダーの SerializationFormat 形式。
      戻り値:
      スペック。

    • inboundChannelAdapter

      public static DebeziumMessageProducerSpec inboundChannelAdapter(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)
      提供された DebeziumEngine.Builder の DebeziumMessageProducerSpec のインスタンスを作成します。
      パラメーター:
      debeziumEngineBuilder - 使用する DebeziumEngine.Builder。
      戻り値:
      スペック。