XJohn

下次见到先打个招呼，不要一上来就加微信。等打过几次招呼之后加微信就顺其自然了

你们是想做低代码，运行时判断字段类型么？那可以提前生成 schema 。（比如 JsonRowDeserializationSchema ）
如果是编译期就能确定类型的话直接用 TypeInformation.of()就可以。

支持一下

我之前在华强北一家店换过 mbp 主板+ipad 屏幕+13pro 后屏，小哥服务态度和收费都挺好的。

就一个问题：
假设部署的节点都不可用了，需要迁移到其他节点，多久启动意味着多久服务不可用。

@2018yuli 那好简单啊，你只是为了处理收集到的设备消息呗，区分设备可以用消息里面的数据，没必要分这么多 topic

如果你说的是 iot 设备，一般会使用基于轻量级 MQTT 协议的 MQ ，设备和 sever 之间维护长连接通信。
如果不是 iot 设备，你可能需要考虑清楚你的场景到底是啥，走 MQ 的方式是不是伪解决方案

我们那叫“通城”