From d3465e119e5795a3addee8e3d3ae0ecc8a99fcc4 Mon Sep 17 00:00:00 2001
From: whycxzp <perryhsu@163.com>
Date: 星期五, 12 五月 2023 16:38:38 +0800
Subject: [PATCH] 更新接口
---
src/main/java/com/whyc/config/KafkaConfig.java | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/whyc/config/KafkaConfig.java b/src/main/java/com/whyc/config/KafkaConfig.java
index a04fe3e..6663719 100644
--- a/src/main/java/com/whyc/config/KafkaConfig.java
+++ b/src/main/java/com/whyc/config/KafkaConfig.java
@@ -14,7 +14,7 @@
@Bean
public NewTopic batchTopic() {
//return new NewTopic("topic_device_data",3,(short)3);
- return new NewTopic("topic_device_data2",1,(short)1);
+ return new NewTopic("topic_device_data2",3,(short)1);
}
//@KafkaListener(topics = "topic_device_data")
--
Gitblit v1.9.1