优化代码

service-api/src/main/java/com/java110/api/kafka/FrontServiceKafka.java

@@ -53,7 +53,7 @@ public class FrontServiceKafka extends BaseController {
         JSONObject param = null;
         try {
             param = JSONObject.parseObject(record.value().toString());
-            ParkingAreaWebsocket.sendInfo(param.toJSONString(), param.getString("paId"));
+            ParkingAreaWebsocket.sendInfo(param.toJSONString(), param.getString("extPaId"));
         } catch (Exception e) {
             logger.error("发送消息失败", e);
         } finally {

service-common/src/main/resources/application-dev.yml

@@ -85,4 +85,4 @@ kafka:
       size: 4096
     linger: 1
     buffer:
-      memory: 40960
+      memory: 1048576