第 5 章 Kafka 中断更改
本节介绍了对 Kafka 的任何需要更改 AMQ Streams 的更改,以便继续工作。
5.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
资源的配置。
请参见以下信息: