taosdata / taosdata/TDengine

inserting data over the TDengine Sink Connector returns java.sql.SQLException: ERROR (0x2319): user is required

Open
#27,971 2 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

bug
Dominant language
C
Stars
25.1k
Forks
5k
Avg merge
4d 59m
Merged PRs (30d)
7

Description

根据官网https://docs.taosdata.com/third-party/collection/kafka/#tdengine-sink-connector-%E7%9A%84%E4%BD%BF%E7%94%A8
TDengine Kafka Connector教程,写入数据报错
taos版本
image
kafka插件版本
image

sink-demo.json 创建实例返回
[root@localhost kafka]# curl -X POST -d @sink-demo.json http://localhost:8089/connectors -H "Content-Type: application/json"
{"name":"TDengineSinkConnector","config":{"connector.class":"com.taosdata.kafka.connect.sink.TDengineSinkConnector","tasks.max":"1","topics":"meters","connection.url":"jdbc:TAOS-RS://192.168.50.1:6041","connection.user":"root","connection.password":"taosdata","connection.database":"power","db.schemaless":"line","data.precision":"ms","key.converter":"org.apache.kafka.connect.storage.StringConverter","value.converter":"org.apache.kafka.connect.storage.StringConverter","errors.tolerance":"all","errors.deadletterqueue.topic.name":"dead_letter_topic","errors.deadletterqueue.topic.replication.factor":"1","name":"TDengineSinkConnector"},"tasks":[],"type":"sink"}

image

cat test-data.txt | /opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.50.37:9092 --topic meters

写入数据报错日志

3781b6d71bed40f2d3eb2bd51168ebc
查看数据库,power创建成功了,表数据没写入

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Research direction

Start with the linked TDengine Kafka Connector documentation and reproduce the failure using sink-demo.json, the shown connection settings, and the connector task logs. Compare the configured JDBC user, database, and connector versions with the reported SQLException; done means the connector task accepts the configuration and records from meters are written to power.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, kafka
Domain
data-engineering, databases
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.