fix bug

zhaoxunyong · Oct 29, 2017 · ee41649 · ee41649
1 parent d84142c
commit ee41649
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 6 deletions.
diff --git a/kafkaclusterconsumerdemo/pom.xml b/kafkaclusterconsumerdemo/pom.xml
@@ -163,7 +163,7 @@
         <artifactId>tomcat7-maven-plugin</artifactId>
         <version>2.2</version>
         <configuration>
-          <url>http://localhost:19017/manager/text</url>
+          <url>http://localhost:19019/manager/text</url>
           <server>tomcat7</server>
           <path>/${project.artifactId}</path>
           <update>true</update>

diff --git a/kafkaclusterconsumerdemo/src/main/java/com/bolingcavalry/service/Processer.java b/kafkaclusterconsumerdemo/src/main/java/com/bolingcavalry/service/Processer.java
@@ -27,7 +27,6 @@ public class Processer implements Runnable {
     static{
         Map<String, String> map = System.getenv();
         TOMCAT_ID = map.get("TOMCAT_SERVER_ID");
-        TOMCAT_ID = "tomcat_consumer1";
     }
 
     public Processer(KafkaStream<String, String> stream, int threadNumber) {
@@ -55,6 +54,6 @@ public void run() {
                     value.message());
         }
         // 3. 表示当前线程执行完成
-        System.out.println("Shutdown Thread:" + this.threadNumber);
+        logger.info("Shutdown Thread:" + this.threadNumber);
     }
 }
diff --git a/...sterproducerdemo/src/main/java/com/bolingcavalry/controller/MessageProduceController.java b/...sterproducerdemo/src/main/java/com/bolingcavalry/controller/MessageProduceController.java
@@ -36,7 +36,6 @@ public class MessageProduceController {
     static{
         Map<String, String> map = System.getenv();
         TOMCAT_ID = map.get("TOMCAT_SERVER_ID");
-        TOMCAT_ID = "tomcat_producer2";
     }
 
     @Autowired

diff --git a/kafkaclusterproducerdemo/src/main/java/com/bolingcavalry/service/BusinessPartition.java b/kafkaclusterproducerdemo/src/main/java/com/bolingcavalry/service/BusinessPartition.java
@@ -18,7 +18,7 @@ public class BusinessPartition implements Partitioner {
      * @param props
      */
     public BusinessPartition(VerifiableProperties props) {
-        //注意 ：
+        super();
     }
 
     public int partition(Object o, int i) {

diff --git a/kafkaclusterproducerdemo/src/main/resources/logback.xml b/kafkaclusterproducerdemo/src/main/resources/logback.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <configuration debug="true">
     <!-- 应用名称 -->
-    <property name="APP_NAME" value="logtest" />
+    <property name="APP_NAME" value="kafkaclusterproducerdemo" />
     <!--日志文件的保存路径,首先查找系统属性-Dlog.dir,如果存在就使用其；否则，在当前目录下创建名为logs目录做日志存放的目录 -->
     <property name="LOG_HOME" value="${log.dir:-logs}/${APP_NAME}" />
     <!-- 日志输出格式 -->