TDengine Sink Connector写入数据报 java.sql.SQLException: ERROR (0x2319): user is required
根据官网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创建成功了,表数据没写入
麻烦提供数据库这一侧的版本信息
大佬, 请问这个写入日志的文件是哪个?我也在解决kafka的问题