taosdata/TDengine

kafka tdengine support NOW()

Open

#24.263 aperta il 28 dic 2023

Vedi su GitHub
 (2 commenti) (0 reazioni) (1 assegnatario)C (5002 fork)batch import
help wantedquestion

Metriche repository

Star
 (24.849 star)
Metriche merge PR
 (Merge medio 1g 1h) (4 PR mergiate in 30 g)

Descrizione

我要想问一下 kafka tdengine 连接器,如何增加字段 记录当前 数据从kafka 消费到 tdengine 的插入时间呢?

kafka tdengine 连接器 如何增加insertDate 为 timestamp 类型的 列并自动写入客户端时间 now ? 不是 _ts

我知道 用sql 插入数据是可以,但是kafka tdengine 连接器 是用的无模式写的,所以我看了源码也没看出来如何解决

Guida contributor