From fc404c81c8d297349648aa16b362e6824ae40946 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Wed, 10 May 2023 07:56:46 +0800
Subject: [PATCH] 'commit'

---
 src/main/java/UnitTest/kafkaConsumerTest.java | 16 ----------------
 1 file changed, 16 deletions(-)

diff --git a/src/main/java/UnitTest/kafkaConsumerTest.java b/src/main/java/UnitTest/kafkaConsumerTest.java
index 9368f3b..be44251 100644
--- a/src/main/java/UnitTest/kafkaConsumerTest.java
+++ b/src/main/java/UnitTest/kafkaConsumerTest.java
@@ -12,21 +12,6 @@ import java.util.*;
 
 public class kafkaConsumerTest {
 
-    /**
-     * 功能：获取kafka的时间戳
-     *
-     * @param dateString
-     * @return
-     * @throws ParseException
-     */
-    public static long getKafkaTimeStamp(String dateString) throws ParseException {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        Date date = sdf.parse(dateString);
-        long millis = date.getTime();
-        long kafkaTimestamp = millis / 1000;
-        return kafkaTimestamp;
-    }
-
     protected static Properties initConfig() {
         Properties props = new Properties();
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "10.10.14.67:9092");
@@ -141,7 +126,6 @@ public class kafkaConsumerTest {
                         }
                     }
                 });*/
-
             }
         }
     }