TDengine icon indicating copy to clipboard operation
TDengine copied to clipboard

TDengine Sink Connector写入数据报 java.sql.SQLException: ERROR (0x2319): user is required

Open wow-byte opened this issue 1 year ago • 1 comments

根据官网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创建成功了,表数据没写入

wow-byte avatar Sep 19 '24 09:09 wow-byte

麻烦提供数据库这一侧的版本信息

yu285 avatar Oct 13 '24 14:10 yu285

大佬, 请问这个写入日志的文件是哪个?我也在解决kafka的问题

ccccccn avatar Oct 22 '24 01:10 ccccccn