taosdata/TDengine

数据订阅 拉取耗时太长

Open

#33.524 geöffnet am 10. Nov. 2025

Auf GitHub ansehen
 (3 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)C (5.002 Forks)batch import
help wantedquestion

Repository-Metriken

Stars
 (24.849 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 1T 1h) (4 gemergte PRs in 30 T)

Beschreibung

网络也正常

社区版 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;

Contributor Guide