第 4 章 Kafka 破坏更改

本节论述了对 Kafka 的任何更改,需要对 AMQ Streams 进行相应的更改才能继续工作。

4.1. 使用 Kafka 示例文件连接器

Kafka 不再在其 CLASSPATHplugin.path 中包含示例文件连接器 file StreamSourceConnectorFileStreamSinkConnector。AMQ Streams 已被更新,您仍然可以使用这些示例连接器。现在,示例必须象任何连接器一样添加到插件路径中。

提供了两个连接器配置文件示例:

  • 示例/connect/kafka-connect-build.yaml 提供了一个 Kafka Connect 构建配置,您可以部署该配置以使用文件连接器构建新的 Kafka 连接镜像。
  • example/connect/source-connector.yaml 提供了将文件连接器部署为 KafkaConnector 资源所需要的配置。

请参阅 部署 KafkaConnector 资源示例并使用连接器插件扩展 Kafka 连接