wx163

tmq_get_table_name can't get table name

11

TDengine Version OS: Linux CentOS TDengine Version: 3.2.3.0.alpha 在订阅的参数中，已经增加 tmq_conf_set(conf, "msg.with.table.name", "true") ，但是在返回结果中通过 tmq_get_table_name 获取不到表名，返回结果为空，以下是c 的源码实现。 #include #include #include #include #include #include "taos.h" static int running = 1; const char*...

connect 异常

1

根据官方网站的技术文档 ，https://www.taosdata.com/chinese/12592.html 进行 sink尝试，在 sink-test.properties 中 name=TDengineSinkConnector connector.class=com.taosdata.kafka.connect.sink.TDengineSinkConnector tasks.max=1 topics=meters connection.url=jdbc:TAOS://127.0.0.1:6030 connection.user=root connection.password=taosdata connection.database=power db.schemaless=line key.converter=org.apache.kafka.connect.storage.StringConverter value.converter=org.apache.kafka.connect.storage.StringConverter tasks.max=1 情况下，入库数据失败，改为 大于等于2，可看到数据成功写入到TD。在 tasks.max=1的情况下，出错信息如下： [2022-12-12 21:19:29,728] INFO Kafka Connect standalone worker initializing ......