diff options
| author | lifengchao <[email protected]> | 2024-10-24 17:25:50 +0800 |
|---|---|---|
| committer | lifengchao <[email protected]> | 2024-10-24 17:25:50 +0800 |
| commit | cd80b3884314d5d457c973f0ef99d589313e30e7 (patch) | |
| tree | 4a8635db5e9c57e49501927e1670f137670f10cd /groot-common | |
| parent | 1d422a44bbaaa845f6bccb2b4751fa7dcac81144 (diff) | |
[feature][connector-kafka] GAL-681 kafka connector 支持配置解析kafka record headers
Diffstat (limited to 'groot-common')
| -rw-r--r-- | groot-common/src/main/java/com/geedgenetworks/common/Event.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/groot-common/src/main/java/com/geedgenetworks/common/Event.java b/groot-common/src/main/java/com/geedgenetworks/common/Event.java index 4ab4aef..7733c66 100644 --- a/groot-common/src/main/java/com/geedgenetworks/common/Event.java +++ b/groot-common/src/main/java/com/geedgenetworks/common/Event.java @@ -8,6 +8,7 @@ import java.util.Map; @Data public class Event implements Serializable { public static final String INTERNAL_TIMESTAMP_KEY = "__timestamp"; + public static final String INTERNAL_HEADERS_KEY = "__headers"; public static final String WINDOW_START_TIMESTAMP = "__window_start_timestamp"; public static final String WINDOW_END_TIMESTAMP = "__window_end_timestamp"; |