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 连接器 是用的无模式写的，所以我看了源码也没看出来如何解决

贡献者指南

研究方向
审查 Kafka TDengine 连接器的源代码（可能在仓库的 'connector' 或 'kafka' 目录中），以了解如何处理数据插入。查找自动时间戳列的配置选项。检查问题评论中是否有维护者的指导或计划实现。检查其他连接器中是否已有类似功能。
技术栈
c
领域
backenddatabase
议题类型
功能
难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。
2
预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。
半天
活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。
活跃
清晰度议题是否清楚说明期望改动、验收标准和下一步。
基本清晰
前置要求
Git
新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。
50