第 7 章 Kafka 中断更改
本节介绍了对 Kafka 的任何需要更改 AMQ Streams 的更改,以便继续工作。
7.1. 使用 Kafka 的示例文件连接器 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Kafka 不再在其 CLASSPATH 和 plugin.path 中包含示例文件连接器 FileStreamSourceConnector 和 FileStreamSinkConnector。AMQ Streams 已更新,您仍然可以使用这些示例连接器。现在,必须将示例添加到插件路径中,如任何连接器。
提供了两个连接器配置文件示例:
-
examples/connect/kafka-connect-build.yaml提供了一个 Kafka Connect构建配置,您可以部署以使用文件连接器构建新的 Kafka Connect 镜像。 -
examples/connect/source-connector.yaml提供了部署文件连接器作为KafkaConnector资源的配置。
请参见以下信息: