初始化

iot-machine-state-event-generator-job/pom.xml

@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>iot-machine-state-evnet-generator-job</artifactId>
+    <artifactId>iot-machine-state-event-generator-job</artifactId>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -21,6 +21,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.qniao</groupId>
+            <artifactId>iot-machine-data-event</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>com.qniao</groupId>
             <artifactId>ddd-event</artifactId>

iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java

@@ -1,5 +1,7 @@
 package com.qniao.iot.machine.event.generator.job;
 
+import com.qniao.iot.machine.event.MachineIotDataReceivedEvent;
+import com.qniao.iot.machine.event.MachineIotDataReceivedEventKafkaDeserializationSchema;
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.connector.kafka.source.KafkaSource;
 import org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer;
@@ -17,7 +19,7 @@ public class IotMachineEventGeneratorJob {
                 .setTopics("root_cloud_iot_report_data_event")
                 .setGroupId("root_cloud_iot_data_etl")
                 .setStartingOffsets(OffsetsInitializer.earliest())
-                .setValueOnlyDeserializer(new RootCloudIotDataReceiptedEventDeserializationSchema())
+                .setValueOnlyDeserializer(new MachineIotDataReceivedEventKafkaDeserializationSchema())
                 .build();
     }
 }

pom.xml

@@ -26,7 +26,6 @@ under the License.
     <modules>
         <module>iot-machine-data-event</module>
         <module>iot-machine-state-event-generator-job</module>
-        <module>iot-machine-data-event</module>
     </modules>
     <packaging>pom</packaging>
 </project>