From e63be468d0f31f248d37d0565ae3727666680d6c Mon Sep 17 00:00:00 2001 From: zhouwentao <1577701412@qq.com> Date: Sun, 24 Sep 2023 21:22:41 +0800 Subject: [PATCH] updates --- src/main/java/com/example/zxweb/controller/KafkaController.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/com/example/zxweb/controller/KafkaController.java b/src/main/java/com/example/zxweb/controller/KafkaController.java index d5684de..6a7fa0b 100644 --- a/src/main/java/com/example/zxweb/controller/KafkaController.java +++ b/src/main/java/com/example/zxweb/controller/KafkaController.java @@ -65,6 +65,7 @@ public class KafkaController { JSONArray jsonArray=new JSONArray(); for (ConsumerRecord consumerRecord : records) { String kfkContent = consumerRecord.value(); + System.out.println(kfkContent); resultList.add(kfkContent); if (!StringUtils.isEmpty(kfkContent)) { jsonArray.add(JSONObject.parseObject(kfkContent));