screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -39,7 +39,6 @@ public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception { String messageStr = record.value(); Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr); log.info(message.toString()); //long serverStartTime = System.currentTimeMillis(); CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets; for (SingleDeviceServer socket : sockets) {