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 节点上都必须提供插件。