SMQTTX是一款开源的MQTT消息代理Broker
转发数据到kafka中
前提是必须配置kafka source
smqtt: rules: # 规则引擎相关配置 - ruleName: 过滤 chain: # 规则链 - ruleType: KAFKA # KAFKA过滤器 script: "{'topic':topic,'body':body,'qos':qos}"
PREDICATE节点 HTTP节点