This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit f1280bdd2b9bafd39206852271a722a41fecc9d7 Author: Claus Ibsen <[email protected]> AuthorDate: Wed Jun 9 10:40:48 2021 +0200 CAMEL-16627: camel-core - Add common header for source timestamp --- .../main/java/org/apache/camel/component/debezium/DebeziumEndpoint.java | 1 + 1 file changed, 1 insertion(+) diff --git a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumEndpoint.java b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumEndpoint.java index 9cb5e1a..19f1c4e 100644 --- a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumEndpoint.java +++ b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumEndpoint.java @@ -90,6 +90,7 @@ public abstract class DebeziumEndpoint<C extends EmbeddedDebeziumConfiguration> message.setHeader(DebeziumConstants.HEADER_OPERATION, operation); message.setHeader(DebeziumConstants.HEADER_BEFORE, before); message.setHeader(DebeziumConstants.HEADER_TIMESTAMP, timestamp); + message.setHeader(Exchange.MESSAGE_TIMESTAMP, timestamp); message.setBody(body);
