update kafka & topic

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

@@ -16,7 +16,8 @@ import java.util.List;
 public class LogsHandleWorker implements MultipleWorkerEvent<String> {
     private static final Logger ADAPTER_ERROR_LOG = LoggerFactory.getLogger("adapter.error");
     private static final Logger SYS_ERROR_LOG = LoggerFactory.getLogger("sys.error");
-    private static final String TOPIC = "ets_app_topic";
+//    private static final String TOPIC = "ets_app_topic";
+    private static final String TOPIC = "event_topic";
     private KafkaTemplate<String, String> kafka;
 
     public LogsHandleWorker(KafkaTemplate<String, String> kafka){
@@ -49,7 +50,7 @@ public class LogsHandleWorker implements MultipleWorkerEvent<String> {
     }
 
     public void send(String log){
-        kafka.send(TOPIC,log);
+        kafka.send(TOPIC, log);
     }
 
     @Override

src/main/resources/application.yml

@@ -16,7 +16,8 @@ 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.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
     producer:
       # # 消息重发的次数。 配置事务的话：如果用户显式地指定了 retries 参数，那么这个参数的值必须大于0
       retries: 0