调整KFKA数据推送测试。

jiazx0107@163.com

2024-01-01 d454e51e06dbf7beb50551588fc58a5810295d7c

 src/main/java/com/fzzy/protocol/fzzy/cmd/BaseRemoteImpl.java

@@ -41,7 +41,7 @@
    }

    public InvokeResult send(SendMessage message) {
        log.debug("平台发送报文---->>控制柜--{}", message.toString());
       // log.debug("平台发送报文---->>控制柜--{}", message.toString());
        IoSessionQuery sessionFactory = FzzyServerEngine.ioServer.getSessionQuery();
        List<IoSession> sessions = sessionFactory.getAllSession();
        IoSession session = null;