修复采集器在log4j不能心跳自启的bug

JThink · JThink · commit d00df5d98c1d · 2017-11-21T16:59:16.000+08:00
diff --git a/build.gradle b/build.gradle
@@ -4,7 +4,7 @@ allprojects {
   apply plugin: 'eclipse'
 
   group = 'skyeye'
-  version = '1.2.1'
+  version = '1.2.2'
 
   sourceCompatibility = 1.8
   targetCompatibility = 1.8
diff --git a/skyeye-client/skyeye-client-log4j/src/main/java/com/jthink/skyeye/client/log4j/appender/KafkaAppender.java b/skyeye-client/skyeye-client-log4j/src/main/java/com/jthink/skyeye/client/log4j/appender/KafkaAppender.java
@@ -148,7 +148,7 @@ public void onCompletion(RecordMetadata recordMetadata, Exception e) {
                     if (flag.get() == true) {
                         KafkaAppender.this.heartbeatStart();
                         zkRegister.write(Constants.SLASH + app + Constants.SLASH + host, NodeMode.EPHEMERAL,
-                                String.valueOf(Constants.APP_APPENDER_RESTART_KEY + Constants.SEMICOLON + System.currentTimeMillis()) + Constants.SEMICOLON + SysUtil.userDir);
+                                String.valueOf(Constants.APP_APPENDER_STOP_KEY + Constants.SEMICOLON + System.currentTimeMillis()) + Constants.SEMICOLON + SysUtil.userDir);
                         flag.compareAndSet(true, false);
                     }
                 }

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ public void onCompletion(RecordMetadata recordMetadata, Exception e) {`
`148`	`148`	`if (flag.get() == true) {`
`149`	`149`	`KafkaAppender.this.heartbeatStart();`
`150`	`150`	`zkRegister.write(Constants.SLASH + app + Constants.SLASH + host, NodeMode.EPHEMERAL,`
`151`		`- String.valueOf(Constants.APP_APPENDER_RESTART_KEY + Constants.SEMICOLON + System.currentTimeMillis()) + Constants.SEMICOLON + SysUtil.userDir);`
	`151`	`+ String.valueOf(Constants.APP_APPENDER_STOP_KEY + Constants.SEMICOLON + System.currentTimeMillis()) + Constants.SEMICOLON + SysUtil.userDir);`
`152`	`152`	`flag.compareAndSet(true, false);`
`153`	`153`	`}`
`154`	`154`	`}`