reactor the flink log kafka appender

Author: zhisheng17

flink-learning-extends/FlinkLogKafkaAppender/KafkaAppenderCommon/pom.xml

@@ -0,0 +1,15 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>FlinkLogKafkaAppender</artifactId>
+        <groupId>com.zhisheng.flink</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>KafkaAppenderCommon</artifactId>
+
+    <name>KafkaAppenderCommon</name>
+
+
+</project>

flink-learning-extends/FlinkLogKafkaAppender/Log4j2KafkaAppender/src/main/java/com/zhisheng/log/model/LogEvent.java renamed to flink-learning-extends/FlinkLogKafkaAppender/KafkaAppenderCommon/src/main/java/com/zhisheng/flink/model/LogEvent.java

@@ -1,4 +1,4 @@
-package com.zhisheng.log.model;
+package com.zhisheng.flink.model;
 
 import lombok.Data;
 

flink-learning-extends/FlinkLogKafkaAppender/Log4jKafkaAppender/src/main/java/com/zhisheng/log/util/ExceptionUtil.java renamed to flink-learning-extends/FlinkLogKafkaAppender/KafkaAppenderCommon/src/main/java/com/zhisheng/flink/util/ExceptionUtil.java

@@ -1,4 +1,4 @@
-package com.zhisheng.log.util;
+package com.zhisheng.flink.util;
 
 import java.io.ByteArrayOutputStream;
 import java.io.OutputStream;

flink-learning-extends/FlinkLogKafkaAppender/Log4jKafkaAppender/src/main/java/com/zhisheng/log/util/JacksonUtil.java renamed to flink-learning-extends/FlinkLogKafkaAppender/KafkaAppenderCommon/src/main/java/com/zhisheng/flink/util/JacksonUtil.java

@@ -1,4 +1,4 @@
-package com.zhisheng.log.util;
+package com.zhisheng.flink.util;
 
 
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessingException;

flink-learning-extends/FlinkLogKafkaAppender/Log4j2KafkaAppender/pom.xml

@@ -19,6 +19,11 @@
 
 
     <dependencies>
+        <dependency>
+            <groupId>com.zhisheng.flink</groupId>
+            <artifactId>KafkaAppenderCommon</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.logging.log4j</groupId>
             <artifactId>log4j-slf4j-impl</artifactId>

flink-learning-extends/FlinkLogKafkaAppender/Log4j2KafkaAppender/src/main/java/com/zhisheng/log/appender/KafkaLog4j2Appender.java

@@ -1,8 +1,8 @@
 package com.zhisheng.log.appender;
 
-import com.zhisheng.log.model.LogEvent;
-import com.zhisheng.log.util.ExceptionUtil;
-import com.zhisheng.log.util.JacksonUtil;
+import com.zhisheng.flink.model.LogEvent;
+import com.zhisheng.flink.util.ExceptionUtil;
+import com.zhisheng.flink.util.JacksonUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessingException;
 import org.apache.kafka.clients.producer.KafkaProducer;

flink-learning-extends/FlinkLogKafkaAppender/Log4j2KafkaAppender/src/main/java/com/zhisheng/log/util/ExceptionUtil.java

@@ -19,6 +19,11 @@
 
 
     <dependencies>
+        <dependency>
+            <groupId>com.zhisheng.flink</groupId>
+            <artifactId>KafkaAppenderCommon</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-log4j12</artifactId>

flink-learning-extends/FlinkLogKafkaAppender/Log4j2KafkaAppender/src/main/java/com/zhisheng/log/util/JacksonUtil.java

@@ -1,8 +1,8 @@
 package com.zhisheng.log.appender;
 
-import com.zhisheng.log.model.LogEvent;
-import com.zhisheng.log.util.ExceptionUtil;
-import com.zhisheng.log.util.JacksonUtil;
+import com.zhisheng.flink.model.LogEvent;
+import com.zhisheng.flink.util.ExceptionUtil;
+import com.zhisheng.flink.util.JacksonUtil;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessingException;