taosdata/TDengine

数据订阅 拉取耗时太长

Open

#33.524 aberto em 10 de nov. de 2025

Ver no GitHub
 (3 comments) (0 reactions) (0 assignees)C (5.002 forks)batch import
help wantedquestion

Métricas do repositório

Stars
 (24.849 stars)
Métricas de merge de PR
 (Mesclagem média 1d 1h) (4 fundiu PRs em 30d)

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;

Guia do colaborador