Kafka source connector使用
版本情况
TDengine 3.3.6.13
kafka connector版本:taosdata-kafka-connect-tdengine-1.1.6.zip
配置说明
![]()
问题说明
在按照文档TDengine TSDB Kafka Connector | TDengine 文档 | 涛思数据 配置后,输入数据始终无法自动创建topic,导致无法采集数据。
TDengine 3.3.6.13
![]()
在按照文档TDengine TSDB Kafka Connector | TDengine 文档 | 涛思数据 配置后,输入数据始终无法自动创建topic,导致无法采集数据。
微信 具体排查一下 a15652223354
同楼主问题
| 组件 | 版本/说明 |
|---|---|
| 操作系统 | Linux(Euler24.03) |
| Java | OpenJDK 8 |
| Kafka | 3.9.1(使用 KRaft) |
| TDengine Client | 3.3.6.13 |
| JDBC Driver | taos-jdbcdriver-3.4.0.jar |
| Kafka Connect 插件 | taosdata-kafka-connect-tdengine-1.1.6.zip |
| sink连接器可以正常使用,source连接器日志报错 |
Caused by: java.lang.IllegalAccessError:
tried to access class org.apache.kafka.common.utils.SystemTime
from class com.taosdata.kafka.connect.source.TDengineSourceTask
是否是kafka版本和插件包的兼容性问题?
先调整下驱动的版本
一样的问题,我怀疑是kafka的kraft模式不支持,我是kafka 4.0,tdengine 3.3.6.13,sink可以正常使用,source报一样的错
我们只验证过3.4.0,再新的版本没有验证过。可能是不适配。文档已经修改。
此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。