判断遥测数据是否包含某个字段,包含则转发遥测数据到 Kafka,并附加 metadata 到 header
示例:https://github.com/1962247851/ordinaryroad-ioe/blob/main/ordinaryroad-ioe-web/src/main/java/tech/ordinaryroad/ioe/KafkaConsumer.java
script
if (msg.p) { return true; } else { return false; }
if (msg.p) { return true; } else { return false; }
kakfa