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