如何在本地部署 apache kafka connect（无需 Confluent）

Question

我找不到任何关于Apache Kafka Connect如何实际工作的简单解释。例如，在官方教程中，它说我们在bin目录下运行某些shell脚本，我们需要配置一些.属性文件。

这很清楚。我猜我们需要克隆整个apache kafka源代码，因为这些shell文件在apache kafka源代码中使用了许多其他shell脚本和java类。

但是，我们将连接器代码放在哪里，以何种格式放置呢？作为源代码还是作为jar文件？当我们说我的连接器类是“com.example ...”为什么Kafka知道去哪里找它？有人可以澄清这些或指出一些教程吗？注意，我正在运行所有的东西，包括我的本地kubernetes kafka集群，我不愿意使用Confluent。

Answer 1

克隆整个阿帕奇Kafka源代码

假的。Apache Kafka下载(二进制文件，不是源代码)，已经包含Kafka Connect。

Kafka Connect并非Confluent独有。他们（和其他人）编写插件。您将代码放入插件中。path属性值作为JAR。相关-使用汇流轮毂而不安装汇流平台

当我们说我的连接器类是“com.example.…”Kafka怎么知道去哪里找它？

JVM类路径。

kubernetes kafka集群本地

Strimzi拥有类型：KafkaConnect资源，包括安装连接器插件。