From 6bdf0e83906004b11558b8f6a72643d7837c7afb Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 28 Jun 2021 11:18:34 +0800
Subject: [PATCH] screen-manage 修复查询型号对应因子分页BUG
---
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondsDataConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
similarity index 92%
rename from screen-api/src/main/java/com/moral/api/kafka/consumer/SecondsDataConsumer.java
rename to screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
index 6b412cd..6865acf 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondsDataConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -20,9 +20,9 @@
* @Version TODO
**/
//@Component
-public class SecondsDataConsumer implements ConsumerSeekAware {
+public class SecondDataConsumer implements ConsumerSeekAware {
- @KafkaListener(topics = "test",groupId = "SecondsDataGroup3")
+ @KafkaListener(topics = "second_data",groupId = "SecondsDataGroup3")
public void listen(ConsumerRecord<String, String> record , Consumer consumer) throws Exception {
String messageStr = record.value();
Map<String,String> message = (Map<String,String>)JSON.parse(messageStr);
--
Gitblit v1.8.0