加入机器事件的依赖

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

@@ -26,6 +26,11 @@
             <artifactId>printing-packaging-factory-service-event</artifactId>
             <version>0.0.1-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.qniao</groupId>
+            <artifactId>iot-machine-data-event</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
 
         <!-- Apache Flink dependencies -->
         <!-- These dependencies are provided, because they should not be packaged into the JAR file. -->
@@ -131,7 +136,8 @@
                                         implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
                                 <transformer
                                         implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
-                                    <mainClass>com.qniao.iot.machine.event.generator.job.IotMachineEventGeneratorJob</mainClass>
+                                    <mainClass>com.qniao.iot.machine.event.generator.job.IotMachineEventGeneratorJob
+                                    </mainClass>
                                 </transformer>
                             </transformers>
                         </configuration>

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

@@ -14,10 +14,12 @@ public class IotMachineEventGeneratorJob {
 
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         env.enableCheckpointing(60000L, CheckpointingMode.EXACTLY_ONCE);
+
+        // 定义Kafka数据源
         KafkaSource<MachineIotDataReceivedEvent> source = KafkaSource.<MachineIotDataReceivedEvent>builder()
                 .setBootstrapServers(params.get("source.bootstrap.servers"))
                 .setTopics("root_cloud_iot_report_data_event")
-                .setGroupId("root_cloud_iot_data_etl")
+                .setGroupId("iot.machine.generator")
                 .setStartingOffsets(OffsetsInitializer.earliest())
                 .setValueOnlyDeserializer(new MachineIotDataReceivedEventKafkaDeserializationSchema())
                 .build();