We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
根据官网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创建成功了,表数据没写入
The text was updated successfully, but these errors were encountered:
麻烦提供数据库这一侧的版本信息
Sorry, something went wrong.
大佬, 请问这个写入日志的文件是哪个?我也在解决kafka的问题
No branches or pull requests
根据官网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创建成功了,表数据没写入
The text was updated successfully, but these errors were encountered: