kafak数据读取过滤

2019-05-29

kafka

字数统计: 114 | 阅读时长≈ 1 分钟

幅度变化判别：sh kafka-console-consumer.sh –bootstrap-server microservice-dc-1:9092 –topic dis-excess-ampli-chang |grep PLC6.S7300.XNJBJ3_TIME_H
移动平均：sh kafka-console-consumer.sh –bootstrap-server microservice-dc-1:9092 –topic clean-moving-average |grep PLC6.S7300.XNJBJ3_TIME_H
开关量判别：sh kafka-console-consumer.sh –bootstrap-server microservice-dc-1:9092 –topic clean-moving-average |grep PLC6.S7300.XNJBJ3_TIME_H

原始库:sh kafka-console-consumer.sh –bootstrap-server 172.16.245.6:9092 –topic hiacloud-ts-v3 |grep PLC6.S7300.XNJBJ3_TIME_H

sh kafka-console-consumer.sh –bootstrap-server microservice-dc-1:9092 –topic clean-moving-average |grep P17_TXAI_009.In_Channel0

打赏

版权声明： 本博客所有文章除特别声明外，著作权归作者所有。转载请注明出处！