MODIFY

src/main/java/com/bayread/sensors/task/LogsHandleWorker.java

@@ -10,7 +10,6 @@ import org.springframework.kafka.core.KafkaTemplate;
 import sun.misc.BASE64Decoder;
 
 import java.io.IOException;
-import java.io.UnsupportedEncodingException;
 import java.net.URLDecoder;
 import java.nio.charset.StandardCharsets;
 import java.util.List;

src/main/resources/application.yml

@@ -16,8 +16,7 @@ spring:
       test: delivery-test
       prod: delivery-prod
   kafka:
-#    bootstrap-servers:  172.17.243.58:9092,172.17.243.59:9092,172.17.243.60:9092,172.17.243.61:9092,172.17.243.62:9092
-    bootstrap-servers:  172.17.240.2:9092,172.17.240.7:9092,172.17.240.9:9092
+    bootstrap-servers: 172.17.240.130:9092,172.17.240.131:9092,172.17.240.132:9092,172.17.240.133:9092,172.17.240.168:9092
     producer:
       # # 消息重发的次数。 配置事务的话：如果用户显式地指定了 retries 参数，那么这个参数的值必须大于0
       retries: 0