TDengine kafka connect采集报错(0x2603)

我是使用的kafka connect里面的standalone模式去启动的服务,我的配置文件如下:

name=TDengineSourceConnector

connector.class=com.taosdata.kafka.connect.source.TDengineSourceConnector


tasks.max=1


read.method=query


query=SELECT * FROM HTF12_GAS_FLOW


#read.method=subscription
#subscription.group.id=source-rtdb

#subscription.from=earliest


#subscription.wal.only=false


connection.url=jdbc:TAOS-RS://10.2.252.212:6041/rtdbconnection.user=rootconnection.password=historydataconnection.database=rtdb


connection.attempts=3

connection.backoff.ms=5000

topic.prefix=tdenginetopic.delimiter=-


topic.per.stable=false


topic.ignore.db=false

poll.interval.ms=100

fetch.max.rows=100


out.format=line


data.precision=ms


key.converter=org.apache.kafka.connect.storage.StringConvertervalue.converter=org.apache.kafka.connect.storage.StringConverter

以上的配置中我使用的是query模式,但是我改成subscription模式,他们两种模式的报错都是一样的,说表找不到。因为我已经指定我要采集的那张表了,但是报错是另外一张表的找不到,报错如下:

请参考官网的kafka connector 的使用指南: