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