クラスの使用
org.springframework.integration.debezium.dsl.DebeziumMessageProducerSpec
DebeziumMessageProducerSpec を使用するパッケージ
パッケージ
説明
Java DSL 経由で Debezium コンポーネントをサポートするためのクラスを提供します。
org.springframework.integration.debezium.dsl 内の DebeziumMessageProducerSpec 使用
修飾子と型メソッド説明DebeziumMessageProducerSpec.contentType(StringSE contentType) 送信メッセージのコンテンツ型を設定します。DebeziumMessageProducerSpec.enableBatch(boolean enable) ChangeEventバッチモード処理を有効にします。DebeziumMessageProducerSpec.enableEmptyPayload(boolean enabled) tombstone (別名削除) メッセージのサポートを有効にします。DebeziumMessageProducerSpec.headerMapper(HeaderMapper<ListSE<io.debezium.engine.Header<ObjectSE>>> headerMapper) DebeziumMessageProducerSpec.headerNames(StringSE... headerNames) 送信メッセージヘッダーにマップされるChangeEventヘッダー名のカンマ区切りのリスト。static DebeziumMessageProducerSpecDebezium.inboundChannelAdapter(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[], byte[]>> debeziumEngineBuilder) 提供されたDebeziumEngine.BuilderのDebeziumMessageProducerSpecのインスタンスを作成します。static DebeziumMessageProducerSpecDebezium.inboundChannelAdapter(PropertiesSE debeziumConfig) 提供されたネイティブ debeziumPropertiesSE および JSON 直列化形式用のDebeziumMessageProducerSpecのインスタンスを作成します。static DebeziumMessageProducerSpecDebezium.inboundChannelAdapter(PropertiesSE debeziumConfig, ClassSE<? extends io.debezium.engine.format.SerializationFormat<byte[]>> messageFormat, ClassSE<? extends io.debezium.engine.format.SerializationFormat<byte[]>> headerFormat) 提供されたネイティブ debeziumPropertiesSE および直列化形式用のDebeziumMessageProducerSpecのインスタンスを作成します。DebeziumMessageProducerSpec.taskExecutor(TaskExecutor taskExecutor) Debezium エンジンにはTaskExecutorを設定。