@Scheduled(cron = "0/30 * * * * ? ")
    public void testKafkaGpsData() {
        Random random =new Random();
        for (int i = 0; i < cars.length; i++) {
            GpsLocationDTO gps = new GpsLocationDTO();
            gps.setAlarm(random.nextInt(12)+1);
            gps.setAltitude(random.nextInt(3000)+1000);
            gps.setCompany("GPS测试数据");
            gps.setDataLength(gps.toString().getBytes().length);
            gps.setDataType(random.nextInt(30));
            gps.setLat(String.valueOf(random.nextDouble()*100 + 100));
            gps.setLon((String.valueOf(random.nextDouble()*100)));
            gps.setDirection(random.nextInt(359));
            gps.setLocTime(DateUtils.getCurMiDate(new Date()));
            gps.setVec1(random.nextInt(300)+1);
            gps.setVehicleColor(String.valueOf(random.nextInt(3)));
            gps.setVehicleNo(cars[i]);
            commonKafkaService.sendGpsMsg(gps);
        }
    }


    private static final String[] cars = {"京ABP001",
            "京ABP002",
            "京ABP003"}

public class GpsLocationDTO {
    /**
     * 公司名
     */
    private String company;
    /**
     * 车牌号
     */
    private String vehicleNo;
    /**
     * 车牌颜色
     */
    private String vehicleColor;
    /**
     * 子业务类型标识
     */
    private int dataType;
    /**
     * 后续数据长度
     */
    private int dataLength;
    /**
     * 定位信息采集时间
     */
    private String locTime;
    /**
     * 经度
     */
    private String lon;
    /**
     * 纬度
     */
    private String lat;
    /**
     * 速度
     */
    private int vec1;
    /**
     * 行驶记录速度
     */
    private int vec2;
    /**
     * 车辆当前总里程数
     */
    private int vec3;
    /**
     * 方向
     */
    private int direction;
    /**
     * 海拔
     */
    private int altitude;
    /**
     * 车辆状态
     */
    private int state;
    /**
     * 报警状态
     */
    private int alarm;
    /**
     * 里程
     */
    private double odometer;
}