7.3. 连接器插件
AMQ Streams 中包含了以下连接器插件。
- FileStreamSink
- 从 Kafka 主题读取数据并将数据写入文件。
- FileStreamSource
- 从文件中读取数据并将数据发送到 Kafka 主题。
如果需要,您可以添加更多连接器插件。Kafka Connect 会在启动时搜索并运行额外的连接器插件。要定义 kafka Connect 搜索插件的路径,请设置 plugin.path 配置选项 :
plugin.path=/opt/kafka/connector-plugins,/opt/connectors
plugin.path=/opt/kafka/connector-plugins,/opt/connectors
plugin.path 配置选项可以包含以逗号分隔的路径列表。
当以分布式模式运行 Kafka Connect 时,在所有 worker 节点上都必须提供插件。