inserting data over the TDengine Sink Connector returns java.sql.SQLException: ERROR (0x2319): user is required
Nobody has claimed this yet.
- 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版本
kafka插件版本
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"}
cat test-data.txt | /opt/kafka/bin/kafka-console-producer.sh --broker-list 192.168.50.37:9092 --topic meters
写入数据报错日志
查看数据库,power创建成功了,表数据没写入
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- 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