From 6c5658432934f182cfc5a7c5362c53080cbd27cf Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Fri, 10 Sep 2021 08:56:28 +0800
Subject: [PATCH] gov_monitor_point表相关文件，查询与新增接口
---
screen-api/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java | 12 ------------
1 files changed, 0 insertions(+), 12 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
index af6c8cc..fc0e81c 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
@@ -1,13 +1,7 @@
package com.moral.api.kafka.consumer;
-import com.moral.api.constant.TopicConstants;
import lombok.extern.slf4j.Slf4j;
-import org.apache.kafka.clients.consumer.ConsumerRecord;
-import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.kafka.support.Acknowledgment;
import org.springframework.stereotype.Component;
-
-import java.util.Random;
@Component
@Slf4j
@@ -27,11 +21,5 @@
log.info(String.format("kafka ������������������---------------- listen1 topic = %s, offset = %d, value = %s ", record.topic(), record.offset(), record.value()));
ack.acknowledge();
}
-
}*/
-
-
-
-
-
}
--
Gitblit v1.8.0