From 6ce064cbfb9349371e6efdd71ba32bff647a349e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=85=B4=E7=90=B3?= <1911390090@qq.com> Date: Tue, 8 Apr 2025 11:41:01 +0800 Subject: [PATCH] =?UTF-8?q?kafka=20=E8=BE=93=E5=87=BA=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business/message/device/subscribe/KafkaTopicProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java b/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java index bd2b0351..417d447d 100644 --- a/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java +++ b/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java @@ -46,7 +46,7 @@ public class KafkaTopicProducer { ProducerRecord record = new ProducerRecord<>(topic, event); RecordMetadata metadata = producer.send(record).get(); // 数据信息 - log.info(record.key(), record.value(), metadata.partition(), metadata.offset()); + // log.info(record.key(), record.value(), metadata.partition(), metadata.offset()); } catch (ExecutionException | InterruptedException e) { e.printStackTrace(); } finally {