8.3. 连接器插件

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

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

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

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

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

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

当在分布式模式下运行 Kafka Connect 时，所有 worker 节点上都必须提供插件。