 lpd
|
6d277e9a39
add: 增加消息发送时kafka服务状态检测
|
3 years ago |
|
lpd
|
d041385fae
feat: Kafka消费者分片接收图片数据
|
3 years ago |
|
lpd
|
6074bf0ca2
feat: Kafka消息发送者路径和消费者消费路径全部附加了前缀
|
3 years ago |
|
lpd
|
7496eeb986
add: 增加kafka消费时长配置参数
|
3 years ago |
|
lpd
|
1eeaffbc3c
feat：取消该消费者，由Link层消费
|
3 years ago |
|
lpd
|
493757d799
feat：kafka消费由自动提交改为手动提交
|
3 years ago |
|
lpd
|
823c59ce91
feat: kafka默认消费调整为单次
|
3 years ago |
|
刘培栋
|
cc27d612e4
Merge branch 'develop' of xfz/qhiot-kafka into master
|
3 years ago |
 xufz
|
59cb765456
feat: 1.网关在线离线数据存与influxdb
|
3 years ago |
|
lpd
|
63df58ed1b
feat：jar包升级为1.1.1版本
|
3 years ago |
|
lpd
|
d15efefd2b
feat：调整Kafka序列化方式
|
3 years ago |
|
刘培栋
|
e34a81f511
Merge branch 'develop' of xfz/qhiot-kafka into master
|
3 years ago |
|
xufz
|
5612351ac3
feat: 告警数据transport_warning表转存influxdb
|
3 years ago |
|
lpd
|
317ede7774
fix：移除未使用通道
|
3 years ago |
|
lpd
|
5030cab346
feat：增加TagCacheData、stationMonitoringHistoryData消息队列处理
|
3 years ago |
|
刘培栋
|
0880797dbb
Merge branch 'develop' of xfz/qhiot-kafka into master
|
3 years ago |
|
xufz
|
cadc3d680a
feat： 调整原insight.kapacitor.queue、third.univesal.data.queue队列
|
3 years ago |
|
lpd
|
9b3c6d6699
fix：修正一些依赖报错
|
3 years ago |
|
lpd
|
8a817a7298
fix：修正一些依赖报错
|
3 years ago |
|
lpd
|
e0068b5f7b
feat：调整insight.data.queue，api.data.queue消费者
|
3 years ago |
|
lpd
|
758d553909
feat：调整insight.warning.queue队列
|
3 years ago |
|
lpd
|
361036dcda
feat：调整部分队列通道
|
3 years ago |
|
lpd
|
c80b86693d
feat：增加Kafka发送对象无参构造方法
|
3 years ago |
|
lpd
|
452ffd2016
feat：拆分继承自Data对象部分消息
|
3 years ago |
|
lpd
|
80bcfc8835
feat：transport.request，transport.response队列调整为kafka
|
3 years ago |
|
刘培栋
|
e29b620c89
Merge branch 'develop' of xfz/qhiot-kafka into master
|
3 years ago |
|
xufz
|
8fb821d3c2
feat: 将transport.data.queue、insight.data.queue、api.data.queue 3个队列合并至transport.data.topic主题队列中
|
3 years ago |
|
刘培栋
|
6808cf3d55
Merge branch 'develop' of xfz/qhiot-kafka into master
|
3 years ago |
|
xufz
|
62d29bf974
feat: kafka替换transport.data.topic、application.logs、codec.log
|
3 years ago |
|
lpd
|
25665bcd1b
demo增加header对象类型解析
|
3 years ago |
