规则引擎使用

使用

目前规则引擎的数据源，一种类型只支持一个实例，通过配置的source枚举类关联

demo

过滤topic1的数据转发到kafka中

smqtt:
    rules: # 规则引擎相关配置
        - ruleName: test-rule
          chain: # 规则链
            - ruleType: PREDICATE  # 条件过滤器
              script: topic.equals("test/test")
            - ruleType: KAFKA  # KAFKA过滤器
              script:   "{'topic':topic,'body':body,'qos':qos}"
    sources: # 配置数据源sources
        - source: KAFKA # kafka配置
          sourceName: kafka
          sourceAttributes:
              topic: testTopic
              bootstrap-servers: 172.16.63.50:9092
              key-serializer: org.apache.kafka.common.serialization.StringSerializer
              value-serializer: org.apache.kafka.common.serialization.StringSerializer