TwitterSourceConnector 必须是 SourceConnector 的子类答案

【问题标题】：TwitterSourceConnector must be subclass of SourceConnectorTwitterSourceConnector 必须是 SourceConnector 的子类
【发布时间】：2021-10-21 14:38:26
【问题描述】：

Kafka Connect 通过docker-compose kafka-cluster 启动，基础来自：landoop/fast-data-dev:lastest，其中最新的最终是 Kafka Connect 版本 2.6.2-LO，还尝试了 2.6.2-哦。两者都未能成功创建和运行连接器。

查看连接器状态时：http://localhost:8083/connectors/source-twitter-distributed/status

我看到下面的跟踪，因为连接器捆绑在一起，我无法理解：

{
    "name": "source-twitter-distributed",
    "connector": {
        "state": "FAILED",
        "worker_id": "127.0.0.1:8083",
        "trace": "org.apache.kafka.connect.errors.ConnectException: Connector implementations must 
be a subclass of either SourceConnector or SinkConnector
at org.apache.kafka.connect.runtime.WorkerConnector.initialize(WorkerConnector.java:162)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:131)
at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:117)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)\n"
    },
    "tasks": [],
    "type": "unknown"
}

有什么见解吗？

【问题讨论】：

您是否尝试过在 Docker 之外使用独立的 Kafka Connect？
@OneCricketeer，没试过。

标签： apache-kafka apache-kafka-connect

【解决方案1】：

不会选择此作为官方答案，但我相信它可能与landoop 版本与连接器更相关。

最终将 landoop/fast-data-dev:latest 更改为 lensesio/fast-data-dev:2.5.1-L1，重新创建了所有内容，现在连接和数据按预期流动。

【讨论】：