This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 774f045 update DBZ doc
774f045 is described below
commit 774f0451f84c827cceb932a0baf6dfcc59227652
Author: winger <[email protected]>
AuthorDate: Thu Aug 26 09:38:46 2021 +0800
update DBZ doc
---
.../camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
b/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
index 74f3c5f..d996b90 100644
---
a/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
+++
b/components/camel-debezium/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
@@ -332,7 +332,8 @@ The following headers are available when consuming change
events from Debezium.
| DebeziumConstants.HEADER_SOURCE_METADATA | "CamelDebeziumSourceMetadata"
| Map | The metadata about the source event, for example
`table` name, database `name`, log position, etc, please refer to the Debezium
documentation for more info.
| DebeziumConstants.HEADER_OPERATION | "CamelDebeziumOperation"
| String | If presents, the type of event operation. Values
for the connector are `c` for create (or insert), `u` for update, `d` for
delete or `r` in case of a snapshot event.
| DebeziumConstants.HEADER_TIMESTAMP | "CamelDebeziumTimestamp"
| Long | If presents, the time (using the system clock in
the JVM) at which the connector processed the event.
-| DebeziumConstants.HEADER_BEFORE | "CamelDebeziumBefore"
| Struct | If presents, contains the state of the row before
the event occurred.
+| DebeziumConstants.HEADER_BEFORE | "CamelDebeziumBefore"
| Struct | If presents, contains the state of the row before
the event occurred.
+| DebeziumConstants.HEADER_DDL_SQL | "CamelDebeziumDdlSQL"
| String | If presents, the ddl sql text of the event.
|===
== Message body
@@ -353,6 +354,7 @@
from("debezium-mysql:dbz-test-1?offsetStorageFileName=/usr/offset-file-1.dat&dat
.log(" on this database '${headers.CamelDebeziumSourceMetadata[db]}'
and this table '${headers.CamelDebeziumSourceMetadata[table]}'")
.log(" with the key ${headers.CamelDebeziumKey}")
.log(" the previous value is ${headers.CamelDebeziumBefore}")
+ .log(" the ddl sql text is ${headers.CamelDebeziumDdlSQL}")
----
By default, the component will emit the events in the body and
`CamelDebeziumBefore` header as
https://kafka.apache.org/22/javadoc/org/apache/kafka/connect/data/Struct.html[`Struct`]
data type, the reasoning behind this, is to perceive the schema information in
case is needed.
