From 8228b06f808840d95d58e4ad457e072800af33e6 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Wed, 09 Mar 2022 11:35:00 +0800
Subject: [PATCH] 校准公式工具类修改
---
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