
构建数据管道
|
109
{"connector.class":"FileStreamSink","file":"copy-of-server-
properties","topics":"kafka-config-topic"}}' | curl -X POST -d @- http://local-
host:8083/connectors --header "content-Type:application/json"
{"name":"dump-kafka-config","config":
{"connector.class":"FileStreamSink","file":"copy-of-server-
properties","topics":"kafka-config-topic","name":"dump-kafka-config"},"tasks":
[]}
这次的配置发生了变化:我们使用了类名 FileStreamSink,而不是 FileStreamSource;文
件属性指向目标文件,而不是原先的文件;我们指定了
topics
,而不是
topic
。可以使用
数据池将多个主题写入一个文件,而一个数据源只允许被写入一个主题。
如果一切正常,你会得到一个叫作 copy-of-server-properties 的文件,该文件的内容与
config/server.properties 完全一样。
如果要删除一个连接器,可以运行下面的命令:
curl -X DELETE http://localhost:8083/connectors/dump-kafka-config ...