第 4 章 Kafka 破坏更改
本节论述了对 Kafka 的任何更改,需要对 AMQ Streams 进行相应的更改才能继续工作。
4.1. 使用 Kafka 示例文件连接器
Kafka 不再在其 CLASSPATH 和 plugin.path 中包含示例文件连接器 file StreamSourceConnector 和 FileStreamSinkConnector。AMQ Streams 已被更新,您仍然可以使用这些示例连接器。现在,示例必须象任何连接器一样添加到插件路径中。
提供了两个连接器配置文件示例:
-
示例/connect/kafka-connect-build.yaml提供了一个 Kafka Connect构建配置,您可以部署该配置以使用文件连接器构建新的 Kafka 连接镜像。 -
example/connect/source-connector.yaml提供了将文件连接器部署为KafkaConnector资源所需要的配置。