taosdata/TDengine

kafka tdengine support NOW()

Open

#24,263 建立於 2023年12月28日

在 GitHub 查看
 (2 留言) (0 反應) (1 負責人)C (5,002 fork)batch import
help wantedquestion

倉庫指標

Star
 (24,849 star)
PR 合併指標
 (平均合併 1天 1小時) (30 天內合併 4 個 PR)

描述

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

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

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

貢獻者指南