'commit'

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 {
                         }
                     }
                 });*/
-
             }
         }
     }