8.3. 连接器插件

以下连接器插件包含在 AMQ Streams 中：

FileStreamSink 从 Kafka 主题读取数据并将数据写入文件中。

FileStreamSource 从文件中读取数据，并将数据发送到 Kafka 主题。

如果需要，您可以添加更多连接器插件。Kafka Connect 会在启动时搜索并运行其他连接器插件。要定义 kafka Connect 搜索插件的路径，设置 plugin.path configuration 选项：

plugin.path=/opt/kafka/connector-plugins,/opt/connectors

plugin.path 配置选项可以包含用逗号分开的路径列表。

当以分布式模式运行 Kafka Connect 时，插件必须在所有 worker 节点上可用。