Kafka source connector无法创建topic

Kafka source connector使用

版本情况

TDengine 3.3.6.13


kafka connector版本:taosdata-kafka-connect-tdengine-1.1.6.zip

配置说明

image

问题说明

在按照文档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 天后被自动关闭。不再允许新回复。