kafka-cndc-server | 修改 | dm501后来会产生重复运单记录问题修复

mt 2025年1月2日18:08:35

kafka-cndc-server | 修改 | dm501后来会产生重复运单记录问题修复
mt 2025年1月2日18:08:35
tao.mo
Commit 22e5586b456ff199545c4fad3b1f8a4030af666a 22e5586b 1 parent b84b6ed6
Showing 1 changed file with 1 additions and 0 deletions
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/constants/Constant.java
--- a/server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/constants/Constant.java
View file @22e5586
+++ b/server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/constants/Constant.java
View file @22e5586
@@ -54,6 +54,7 @@ public interface Constant {
                 BaseConstants.CONSIGNMENT_TABLE_COLUMN_KEYS.USER_INPUT_SHIPPER_ACCOUNT,
                 BaseConstants.CONSIGNMENT_TABLE_COLUMN_KEYS.USER_INPUT_ORIGIN_COUNTRY_CODE,
                 BaseConstants.CONSIGNMENT_TABLE_COLUMN_KEYS.USER_INPUT_ORIGIN_COUNTRY,
+                 BaseConstants.BASE_TABLE_COLUMN_KEYS.ID,
                 BaseConstants.BASE_TABLE_COLUMN_KEYS.CREATE_TIME,
                 BaseConstants.BASE_TABLE_COLUMN_KEYS.CREATE_USER_ID,
                 BaseConstants.BASE_TABLE_COLUMN_KEYS.CREATE_USER_NAME,