taosdata/TDengine

数据订阅 拉取耗时太长

Open

#33 524 ouverte le 10 nov. 2025

Voir sur GitHub
 (3 commentaires) (0 réactions) (0 assignés)C (5 002 forks)batch import
help wantedquestion

Métriques du dépôt

Stars
 (24 849 stars)
Métriques de merge PR
 (Merge moyen 1j 1h) (4 PRs mergées en 30 j)

Description

网络也正常

社区版 3.3.8.1

目前的架构是 6台服务器,其中5台tdengine server,第6台服务器 从其他5台通过数据订阅拉取数据, 每台服务器拉取开了5个线程,一共25个线程, 参数: properties.setProperty(TMQConstants.CONNECT_TYPE, "ws"); properties.setProperty(TMQConstants.CONNECT_USER, "root"); properties.setProperty(TMQConstants.CONNECT_PASS, "taosdata"); properties.setProperty(TMQConstants.AUTO_OFFSET_RESET, "latest"); properties.setProperty(TMQConstants.MSG_WITH_TABLE_NAME, "true"); properties.setProperty(TMQConstants.ENABLE_AUTO_COMMIT, "true"); properties.setProperty(TMQConstants.AUTO_COMMIT_INTERVAL, "1000");

5台服务器的数据库创建语句 CREATE DATABASE tpih PRECISION 'ns' KEEP 150 VGROUPS 10 CACHEMODEL 'both' DURATION 24h BUFFER 16;

Guide contributeur