taosdata/TDengine

kafka tdengine support NOW()

Open

#24,263 opened on 2023年12月28日

GitHub で見る
 (2 comments) (0 reactions) (1 assignee)C (5,002 forks)batch import
help wantedquestion

Repository metrics

Stars
 (24,849 stars)
PR merge metrics
 (平均マージ 1d 1h) (30d で 4 merged PRs)

説明

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

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

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

コントリビューターガイド