<dev>

1. 修改打包方式

pom.xml

@@ -132,31 +132,17 @@
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-assembly-plugin</artifactId>
-                <version>2.4.1</version>
+                <artifactId>maven-jar-plugin</artifactId>
                 <configuration>
-                    <!-- get all project dependencies -->
-                    <descriptorRefs>
-                        <descriptorRef>jar-with-dependencies</descriptorRef>
-                    </descriptorRefs>
-                    <!-- MainClass in mainfest make a executable jar -->
                     <archive>
                         <manifest>
-                            <mainClass>top.xiesen.mock.kafka.mock.MockKafkaConnectAvro</mainClass>
+                            <addClasspath>true</addClasspath>
+                            <useUniqueVersions>false</useUniqueVersions>
+                            <classpathPrefix>lib/</classpathPrefix>
+                            <mainClass>com.zorkdata.tools.mock.BuildJarTest</mainClass>
                         </manifest>
                     </archive>
-
                 </configuration>
-                <executions>
-                    <execution>
-                        <id>make-assembly</id>
-                        <!-- bind to the packaging phase -->
-                        <phase>package</phase>
-                        <goals>
-                            <goal>single</goal>
-                        </goals>
-                    </execution>
-                </executions>
             </plugin>
         </plugins>
     </build>

src/META-INF/MANIFEST.MF

+Manifest-Version: 1.0
+Main-Class: com.zorkdata.tools.mock.BuildJarTest
+

src/main/java/com/zorkdta/tools/MockProduct.java → src/main/java/com/zorkdata/tools/MockProduct.java

-package com.zorkdta.tools;
+package com.zorkdata.tools;
 
 import com.alibaba.fastjson.JSON;
-import com.zorkdta.tools.avro.AvroSerializer;
-import com.zorkdta.tools.avro.AvroSerializerFactory;
-import com.zorkdta.tools.pojo.ZorkData;
-import com.zorkdta.tools.utils.DateUtil;
+import com.zorkdata.tools.avro.AvroSerializer;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.pojo.ZorkData;
+import com.zorkdata.tools.utils.DateUtil;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.ByteArraySerializer;

src/main/java/com/zorkdta/tools/avro/AvroDeserializer.java → src/main/java/com/zorkdata/tools/avro/AvroDeserializer.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;

src/main/java/com/zorkdta/tools/avro/AvroDeserializerFactory.java → src/main/java/com/zorkdata/tools/avro/AvroDeserializerFactory.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 /**
  * @author DeleMing

src/main/java/com/zorkdta/tools/avro/AvroSerializer.java → src/main/java/com/zorkdata/tools/avro/AvroSerializer.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;

src/main/java/com/zorkdta/tools/avro/AvroSerializerFactory.java → src/main/java/com/zorkdata/tools/avro/AvroSerializerFactory.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 /**
  * @author DeleMing

src/main/java/com/zorkdta/tools/avro/LogAvroMacroDef.java → src/main/java/com/zorkdata/tools/avro/LogAvroMacroDef.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 /**
  * @author DeleMing

src/main/java/com/zorkdta/tools/avro/MetricAvroMacroDef.java → src/main/java/com/zorkdata/tools/avro/MetricAvroMacroDef.java

-package com.zorkdta.tools.avro;
+package com.zorkdata.tools.avro;
 
 /**
  * @author DeleMing

src/main/java/com/zorkdata/tools/mock/BuildJarTest.java

+package com.zorkdata.tools.mock;
+
+/**
+ * @author: LiaoMingtao
+ * @date: 2020/6/22
+ */
+public class BuildJarTest {
+    public static void main(String[] args) {
+        System.out.println("buildJarTest--start");
+        System.out.println("buildJarTest--end");
+    }
+}

src/main/java/com/zorkdta/tools/mock/KafkaProducerUtil.java → src/main/java/com/zorkdata/tools/mock/KafkaProducerUtil.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
-import com.zorkdta.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
 import lombok.Data;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;

src/main/java/com/zorkdta/tools/mock/MockConnectJsonData.java → src/main/java/com/zorkdata/tools/mock/MockConnectJsonData.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;

src/main/java/com/zorkdta/tools/mock/MockFilebeatDataToKafka.java → src/main/java/com/zorkdata/tools/mock/MockFilebeatDataToKafka.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;

src/main/java/com/zorkdta/tools/mock/MockFlinkxJson.java → src/main/java/com/zorkdata/tools/mock/MockFlinkxJson.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;

src/main/java/com/zorkdta/tools/mock/MockKafkaConnect.java → src/main/java/com/zorkdata/tools/mock/MockKafkaConnect.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.ByteArraySerializer;
-import com.zorkdta.tools.avro.AvroSerializer;
-import com.zorkdta.tools.avro.AvroSerializerFactory;
-import com.zorkdta.tools.utils.DateUtil;
+import com.zorkdata.tools.avro.AvroSerializer;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.utils.DateUtil;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/com/zorkdta/tools/mock/MockKafkaConnectAvro.java → src/main/java/com/zorkdata/tools/mock/MockKafkaConnectAvro.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zorkdta.tools.utils.*;
+import com.zorkdata.tools.utils.*;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/com/zorkdta/tools/mock/MockKafkaConnectAvroTest.java → src/main/java/com/zorkdata/tools/mock/MockKafkaConnectAvroTest.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
-import com.zorkdta.tools.utils.DateUtil;
+import com.zorkdata.tools.utils.DateUtil;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.ByteArraySerializer;
-import com.zorkdta.tools.avro.AvroSerializer;
-import com.zorkdta.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.avro.AvroSerializer;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/com/zorkdta/tools/mock/MockKafkaConnectJson.java → src/main/java/com/zorkdata/tools/mock/MockKafkaConnectJson.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
-import com.zorkdta.tools.utils.CustomerProducer;
-import com.zorkdta.tools.utils.ProducerPool;
-import com.zorkdta.tools.utils.PropertiesUtil;
-import com.zorkdta.tools.utils.StringUtil;
+import com.zorkdata.tools.utils.CustomerProducer;
+import com.zorkdata.tools.utils.ProducerPool;
+import com.zorkdata.tools.utils.PropertiesUtil;
+import com.zorkdata.tools.utils.StringUtil;
 
 import java.util.Properties;
 

src/main/java/com/zorkdta/tools/mock/MockMetricEvent.java → src/main/java/com/zorkdata/tools/mock/MockMetricEvent.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSON;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
-import com.zorkdta.tools.pojo.MetricEvent;
+import com.zorkdata.tools.pojo.MetricEvent;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/com/zorkdta/tools/mock/MockStreamxJson.java → src/main/java/com/zorkdata/tools/mock/MockStreamxJson.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;

src/main/java/com/zorkdta/tools/mock/MockStreamxJson1.java → src/main/java/com/zorkdata/tools/mock/MockStreamxJson1.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.KafkaProducer;

src/main/java/com/zorkdta/tools/mock/MockZorkMetric.java → src/main/java/com/zorkdata/tools/mock/MockZorkMetric.java

-package com.zorkdta.tools.mock;
+package com.zorkdata.tools.mock;
 
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.ByteArraySerializer;
-import com.zorkdta.tools.avro.AvroSerializer;
-import com.zorkdta.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.avro.AvroSerializer;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/com/zorkdta/tools/pojo/MetricEvent.java → src/main/java/com/zorkdata/tools/pojo/MetricEvent.java

-package com.zorkdta.tools.pojo;
+package com.zorkdata.tools.pojo;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/zorkdta/tools/pojo/Rule.java → src/main/java/com/zorkdata/tools/pojo/Rule.java

-package com.zorkdta.tools.pojo;
+package com.zorkdata.tools.pojo;
 
 /**
  * @description:

src/main/java/com/zorkdta/tools/pojo/ZorkData.java → src/main/java/com/zorkdata/tools/pojo/ZorkData.java

-package com.zorkdta.tools.pojo;
+package com.zorkdata.tools.pojo;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

src/main/java/com/zorkdta/tools/test/LogicRule.java → src/main/java/com/zorkdata/tools/test/LogicRule.java

-package com.zorkdta.tools.test;
+package com.zorkdata.tools.test;
 
-import com.zorkdta.tools.pojo.Rule;
+import com.zorkdata.tools.pojo.Rule;
 
 import java.util.Collections;
 import java.util.List;

src/main/java/com/zorkdta/tools/test/ReflectionUtils.java → src/main/java/com/zorkdata/tools/test/ReflectionUtils.java

-package com.zorkdta.tools.test;
+package com.zorkdata.tools.test;
 
-import com.zorkdta.tools.pojo.ZorkData;
+import com.zorkdata.tools.pojo.ZorkData;
 import org.apache.commons.lang.StringUtils;
 
 import java.lang.reflect.Field;

src/main/java/com/zorkdta/tools/test/RegularMatchTest.java → src/main/java/com/zorkdata/tools/test/RegularMatchTest.java

-package com.zorkdta.tools.test;
+package com.zorkdata.tools.test;
 
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;

src/main/java/com/zorkdta/tools/test/Test01.java → src/main/java/com/zorkdata/tools/test/Test01.java

-package com.zorkdta.tools.test;
+package com.zorkdata.tools.test;
 
 import java.util.Properties;
 

src/main/java/com/zorkdta/tools/test/TimeStampTest.java → src/main/java/com/zorkdata/tools/test/TimeStampTest.java

-package com.zorkdta.tools.test;
+package com.zorkdata.tools.test;
 
 import org.joda.time.DateTime;
 import org.joda.time.format.DateTimeFormat;

src/main/java/com/zorkdta/tools/utils/CustomerProducer.java → src/main/java/com/zorkdata/tools/utils/CustomerProducer.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
-import com.zorkdta.tools.avro.AvroSerializerFactory;
+import com.zorkdata.tools.avro.AvroSerializerFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerConfig;

src/main/java/com/zorkdta/tools/utils/DateUtil.java → src/main/java/com/zorkdata/tools/utils/DateUtil.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import org.joda.time.DateTime;
 

src/main/java/com/zorkdta/tools/utils/JConsumerMutil.java → src/main/java/com/zorkdata/tools/utils/JConsumerMutil.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;

src/main/java/com/zorkdta/tools/utils/JProducer.java → src/main/java/com/zorkdata/tools/utils/JProducer.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.*;

src/main/java/com/zorkdta/tools/utils/JProducerThread.java → src/main/java/com/zorkdata/tools/utils/JProducerThread.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.kafka.clients.producer.*;

src/main/java/com/zorkdta/tools/utils/ProducerPool.java → src/main/java/com/zorkdata/tools/utils/ProducerPool.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import java.io.Closeable;
 import java.io.IOException;

src/main/java/com/zorkdta/tools/utils/PropertiesUtil.java → src/main/java/com/zorkdata/tools/utils/PropertiesUtil.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import java.io.File;
 import java.io.FileInputStream;

src/main/java/com/zorkdta/tools/utils/StringUtil.java → src/main/java/com/zorkdata/tools/utils/StringUtil.java

-package com.zorkdta.tools.utils;
+package com.zorkdata.tools.utils;
 
 import org.joda.time.DateTime;