我是使用的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模式,他们两种模式的报错都是一样的,说表找不到。因为我已经指定我要采集的那张表了,但是报错是另外一张表的找不到,报错如下:

