旅行信息插入字段格式不对，bug fixed

realtime/hologram-streaming/src/main/java/com/zhht/irn/sink/TravelMetricSink.java

@@ -9,7 +9,7 @@ import java.sql.Connection;
 import java.sql.PreparedStatement;
 
 import static com.zhht.irn.utils.DateUtils.longToString;
-import static com.zhht.irn.utils.DateUtils.dateFormat;
+import static com.zhht.irn.utils.DateUtils.timeFormat;
 /**
  * 旅行信息指标计算
  *
@@ -48,20 +48,20 @@ public class TravelMetricSink extends RichSinkFunction<Travel> {
         insertPstmt.setString(3, travel.getCrossId());
         insertPstmt.setString(4, travel.getPlate());
         insertPstmt.setString(5, travel.getRecordId());
-        insertPstmt.setString(6, longToString(travel.getFirstTime(), dateFormat));
-        insertPstmt.setString(7, longToString(travel.getLastTime(), dateFormat));
-        insertPstmt.setString(8, longToString(travel.getArrivedTime(), dateFormat));
-        insertPstmt.setString(9, longToString(travel.getInCrossTime(), dateFormat));
-        insertPstmt.setString(10, longToString(travel.getOutCrossTime(), dateFormat));
-        insertPstmt.setString(11, longToString(travel.getAwayTime(), dateFormat));
+        insertPstmt.setString(6, longToString(travel.getFirstTime(), timeFormat));
+        insertPstmt.setString(7, longToString(travel.getLastTime(), timeFormat));
+        insertPstmt.setString(8, longToString(travel.getArrivedTime(), timeFormat));
+        insertPstmt.setString(9, longToString(travel.getInCrossTime(), timeFormat));
+        insertPstmt.setString(10, longToString(travel.getOutCrossTime(), timeFormat));
+        insertPstmt.setString(11, longToString(travel.getAwayTime(), timeFormat));
         insertPstmt.setInt(12, travel.getStopCount());
         insertPstmt.setDouble(13, travel.getStopTime());
         insertPstmt.setDouble(14, travel.getAvgSpeed());
         insertPstmt.setDouble(15, travel.getMinSpeed());
         insertPstmt.setDouble(16, travel.getMaxSpeed());
         insertPstmt.setString(17, DateUtils.getTodayTime());
-        insertPstmt.setString(18, longToString(travel.getTravelBeginTime(), dateFormat));
-        insertPstmt.setString(19, longToString(travel.getTravelEndTime(), dateFormat));
+        insertPstmt.setString(18, longToString(travel.getTravelBeginTime(), timeFormat));
+        insertPstmt.setString(19, longToString(travel.getTravelEndTime(), timeFormat));
         insertPstmt.setString(20, travel.getArrivedLineId());
         insertPstmt.setString(21, travel.getOutCrossLineId());
         insertPstmt.setString(22, travel.getAwayLineId());

realtime/hologram-streaming/src/main/resources/kafka.properties

 bootstrap.servers=10.100.32.173:9092
 kafka.input.topics=trips_info
 auto.offset.reset=earliest
-group.id=test
+group.id=wuyanfei
\ No newline at end of file