add thread

.idea/encodings.xml

@@ -5,6 +5,9 @@
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-common/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-consumer/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/seecoder-logTracking-server/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/testConnect/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/testConnect/src/main/resources" charset="UTF-8" />
   </component>
 </project>

.idea/runConfigurations.xml

@@ -1,10 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="RunConfigurationProducerService">
-    <option name="ignoredProducers">
-      <set>
-        <option value="com.android.tools.idea.compose.preview.runconfiguration.ComposePreviewRunConfigurationProducer" />
-      </set>
-    </option>
-  </component>
-</project>

pom.xml

@@ -24,7 +24,7 @@
     </parent>
     <groupId>com.nju.edu</groupId>
     <artifactId>seecoder-logTracking</artifactId>
-    <version>0.1.0</version>
+    <version>0.1.1</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

seecoder-logTracking-client/pom.xml

@@ -5,13 +5,13 @@
     <parent>
         <artifactId>seecoder-logTracking</artifactId>
         <groupId>com.nju.edu</groupId>
-        <version>0.1.0</version>
+        <version>0.1.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>seecoder-logTracking-client</artifactId>
     <properties>
-        <seecoder-logTracking-version>0.1.0</seecoder-logTracking-version>
+        <seecoder-logTracking-version>0.1.1</seecoder-logTracking-version>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
     </properties>

seecoder-logTracking-client/target/maven-archiver/pom.properties

@@ -1,3 +1,3 @@
 artifactId=seecoder-logTracking-client
 groupId=com.nju.edu
-version=0.1.0
+version=0.1.1

seecoder-logTracking-client/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,5 +1,5 @@
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\exception\LogTrackingException.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\client\logTrackingApi.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\Utils\LogBuilder.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\client\LogTrackingClient.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\Utils\PostHelper.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\Utils\PostHelper.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\client\LogTrackingClient.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\client\logTrackingApi.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\Utils\LogBuilder.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-client\src\main\java\exception\LogTrackingException.java

seecoder-logTracking-common/pom.xml

@@ -5,14 +5,14 @@
     <parent>
         <artifactId>seecoder-logTracking</artifactId>
         <groupId>com.nju.edu</groupId>
-        <version>0.1.0</version>
+        <version>0.1.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
-        <seecoder-logTracking-version>0.1.0</seecoder-logTracking-version>
+        <seecoder-logTracking-version>0.1.1</seecoder-logTracking-version>
     </properties>
 
     <artifactId>seecoder-logTracking-common</artifactId>

seecoder-logTracking-common/target/maven-archiver/pom.properties

@@ -1,3 +1,3 @@
 artifactId=seecoder-logTracking-common
 groupId=com.nju.edu
-version=0.1.0
+version=0.1.1

seecoder-logTracking-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,6 +1,6 @@
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\PublishMode.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\Level.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\Config.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\KafkaUtils.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\dto\LogConfigDto.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\SeecSystem.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\Level.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\Config.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\kafka\KafkaUtils.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\PublishMode.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\dto\LogConfigDto.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-common\src\main\java\com\nju\edu\logTracking\enums\SeecSystem.java

seecoder-logTracking-consumer/pom.xml

@@ -5,14 +5,14 @@
     <parent>
         <artifactId>seecoder-logTracking</artifactId>
         <groupId>com.nju.edu</groupId>
-        <version>0.1.0</version>
+        <version>0.1.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
-        <seecoder-logTracking-version>0.1.0</seecoder-logTracking-version>
+        <seecoder-logTracking-version>0.1.1</seecoder-logTracking-version>
     </properties>
 
     <artifactId>seecoder-logTracking-consumer</artifactId>

seecoder-logTracking-consumer/src/main/java/com/nju/edu/logTracking/LogConsumer.java

@@ -10,16 +10,19 @@ import java.util.Arrays;
 
 public abstract class LogConsumer {
     public void processLog() {
-        KafkaConsumer<String, String> consumer = KafkaUtils
-                .createConsumer(Arrays.asList(Config.Topic.LOG_TRACKING_TOPIC.getTopic()));
-        while (true) {
-            ConsumerRecords<String, String> records = consumer.poll(1000);
-            for (ConsumerRecord<String, String> record : records) {
-                String value = record.value();
-                consumer.commitAsync();
-                run(value);
+        Thread thread = new Thread(()->{
+            KafkaConsumer<String, String> consumer = KafkaUtils
+                    .createConsumer(Arrays.asList(Config.Topic.LOG_TRACKING_TOPIC.getTopic()));
+            while (true) {
+                ConsumerRecords<String, String> records = consumer.poll(1000);
+                for (ConsumerRecord<String, String> record : records) {
+                    String value = record.value();
+                    consumer.commitAsync();
+                    run(value);
+                }
             }
-        }
+        });
+        thread.start();
     }
 
     public abstract void run(String value);

seecoder-logTracking-consumer/target/maven-archiver/pom.properties

@@ -1,3 +1,3 @@
 artifactId=seecoder-logTracking-consumer
 groupId=com.nju.edu
-version=0.1.0
+version=0.1.1

seecoder-logTracking-consumer/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1 +1 @@
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-consumer\src\main\java\com\nju\edu\logTracking\LogConsumer.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-consumer\src\main\java\com\nju\edu\logTracking\LogConsumer.java

seecoder-logTracking-server/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>seecoder-logTracking</artifactId>
         <groupId>com.nju.edu</groupId>
-        <version>0.1.0</version>
+        <version>0.1.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -21,7 +21,7 @@
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
-        <seecoder-logTracking-version>0.1.0</seecoder-logTracking-version>
+        <seecoder-logTracking-version>0.1.1</seecoder-logTracking-version>
     </properties>
 
     <artifactId>seecoder-logTracking-server</artifactId>

seecoder-logTracking-server/target/maven-archiver/pom.properties

@@ -1,3 +1,3 @@
 artifactId=seecoder-logTracking-server
 groupId=com.nju.edu
-version=0.1.0
+version=0.1.1

seecoder-logTracking-server/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,14 +1,14 @@
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\LogTrackingApplication.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\LowLevel.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\controller\LogTrackingController.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\HighLevel.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\Exception\ServiceException.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\Log.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\MediumLevel.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\BatchLog.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\Level.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\service\impl\LogTrackingServiceImpl.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\Exception\ExceptionHandle.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\SingleLog.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\service\LogTrackingService.java
-D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\response\Response.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\Exception\ExceptionHandle.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\MediumLevel.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\service\LogTrackingService.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\Exception\ServiceException.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\service\impl\LogTrackingServiceImpl.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\Log.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\HighLevel.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\Level.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\BatchLog.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\LogTrackingApplication.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\web\response\Response.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\publishMode\SingleLog.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\controller\LogTrackingController.java
+D:\Seecoder\SEEC-LogTracking\seecoder-logTracking-server\src\main\java\com\nju\edu\logTracking\producer\level\LowLevel.java

testConnect/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>seecoder-logTracking</artifactId>
         <groupId>com.nju.edu</groupId>
-        <version>0.1.0</version>
+        <version>0.1.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -14,19 +14,19 @@
         <dependency>
             <groupId>com.nju.edu</groupId>
             <artifactId>seecoder-logTracking-client</artifactId>
-            <version>0.1.0</version>
+            <version>0.1.1</version>
             <scope>compile</scope>
         </dependency>
         <dependency>
             <groupId>com.nju.edu</groupId>
             <artifactId>seecoder-logTracking-consumer</artifactId>
-            <version>0.1.0</version>
+            <version>0.1.1</version>
             <scope>compile</scope>
         </dependency>
         <dependency>
             <groupId>com.nju.edu</groupId>
             <artifactId>seecoder-logTracking-common</artifactId>
-            <version>0.1.0</version>
+            <version>0.1.1</version>
         </dependency>
     </dependencies>
 

testConnect/target/maven-archiver/pom.properties

@@ -1,3 +1,3 @@
 artifactId=testConnect
 groupId=com.nju.edu
-version=0.1.0
+version=0.1.1

testConnect/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1 +1 @@
-D:\SEEC\SEEC-LogTracking\testConnect\src\main\java\Test.java
+D:\Seecoder\SEEC-LogTracking\testConnect\src\main\java\Test.java