修改配置

src/main/java/com/winhc/config/KafkaConfig.java

@@ -52,7 +52,7 @@ public class KafkaConfig {
     @Bean
     public Map<String, Object> producerConfigs() {
         Map<String, Object> props = Maps.newHashMap();
-        props.put(ProducerConfig.ACKS_CONFIG, "0");
+        props.put(ProducerConfig.ACKS_CONFIG, "-1");
         props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
         props.put(ProducerConfig.RETRIES_CONFIG, retries);
         props.put(ProducerConfig.BATCH_SIZE_CONFIG, batchSize);

src/main/java/com/winhc/utils/CompanyUtils.java

@@ -57,4 +57,8 @@ public class CompanyUtils {
     public static String getIncrPersonLabel(){
         return CompanyEnum.Lable.新增.code + DateUtil.formatDate_YYYYMMDD(new Date());
     }
+
+    public static void main(String[] args) {
+        System.out.println(getIncrPersonLabel());
+    }
 }

src/main/java/com/winhc/utils/DateUtil.java

@@ -11,7 +11,6 @@ import java.util.Date;
 /**
  * 日期工具类
  * 
- * @author David.Huang
  */
 public class DateUtil {
 

src/main/resources/application-dev.properties

@@ -24,7 +24,7 @@ scheduling.enabled = false
 
 #============== kafka ===================
 # 指定kafka 代理地址，可以多个
-spring.kafka.bootstrap-servers=106.14.211.187:9092
+spring.kafka.bootstrap-servers=47.100.177.224:9092
 #topic
 spring.kafka.topic_node_relation_union=inc_node_relation_union