1.关于MQTT 1.1 仔细检查mqtt Topic 是否有问题 包括加 Variate| 1.2 EMQX的 CLIENT_ID 请采用 随机的UUID 谢谢 2.关于flink 2.1 部署 入口类 是 包名+入口类名 参数也需要填写 2.2 动态配置 请采用 广播流的方式 2.3 collect请不要用 java的实体类 用scala的样例类 2.4 Scala 的序列化与反序列化 2.5 其他的见代码吧。。。。。。
