我想把streamsql放到kafka中，让flink在cep中使用。这样好吗？
我知道flink上不允许动态模式定义，我需要应用规则，它们可以在无界事件流上更改。
举例说明；
有一个用户界面，用户可以为他们的设备定义规则。假设有一个跟踪服务（比如aws iot hub）保持物理设备的状态，我认为这是一个很好的方法，可以将每个设备的特定规则放入阴影中，当阴影参与者接收到传感器数据时，它可以发出添加了规则的数据，供flink作为规则引擎（通过kafka）使用。所以我想让flink执行我传入的传感器数据（及其规则），对于每个设备可能都不同。
1条答案
按热度按时间34gzjxbg1#
我从你的问题中了解到的是，你想用不同的规则处理不同的流。如果是这样的话，你应该从这些设备发送流到Kafka主题。然后在flink中启动多个cep示例。
每个示例都应该订阅kafka主题（每个主题代表一个设备），并在每个flink示例中添加diff模式。