Initial commit

1 files changed, 46 insertions, 0 deletions

diff --git a/src/main/java/com/zdjizhi/enums/LogMetadata.java b/src/main/java/com/zdjizhi/enums/LogMetadata.java
new file mode 100644
index 0000000..d3a7f49
--- /dev/null
+++ b/src/main/java/com/zdjizhi/enums/LogMetadata.java
@@ -0,0 +1,46 @@
+package com.zdjizhi.enums;
+
+import cn.hutool.core.util.EnumUtil;
+
+/**
+ * @description: \
+ * @author: zhq
+ * @create: 2022-07-05
+ **/
+public enum LogMetadata {
+
+    /*
+     * 日志名称topic,表名
+     * */
+
+    CONNECTION_RECORD_LOG("connection_record_log", "connection_record_log"),
+    CONNECTION_SKETCH_RECORD_LOG("connection_sketch_record_log", "connection_sketch_record_log"),
+    DNS_RECORD_LOG("dns_record_log", "dns_record_log"),
+    ;
+
+    private String source;
+    private String sink;
+
+    LogMetadata() {
+    }
+
+    LogMetadata(String source, String sink) {
+        this.source = source;
+        this.sink = sink;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public String getSink() {
+        return sink;
+    }
+
+    public static String getLogSink(String source) {
+        LogMetadata logMetadata = EnumUtil.fromString(LogMetadata.class, source);
+        return logMetadata.getSink();
+
+    }
+
+}