如何使用具有两种不同配置的同一连接器运行connect standalone?

eivgtgni  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(372)

我使用的接收器连接器有两个不同的接收器(类型相同),连接器需要用两个不同的配置调用。目前,我们正在使用 screen :
启动脚本.sh

screen -dmS conn-one runConnector.sh config/connect-sink-conn-one.properties config/conn-one.properties
screen -dmS conn-two ./bin/runConnector.sh config/conn-two.properties config/conn-two.properties

运行连接器.sh

connect-standalone $1 $2

有没有一种不用gnu屏幕就可以实现的方法?

nwlqm0z1

nwlqm0z11#

这个 bin/connect-standalone.sh 脚本可以使用不同的连接器配置获取多个属性文件。您只需为每个连接器使用不同的名称。例如,你可以这样做:

bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-sink.properties config/connect-file-sink2.properties

哪里 config/connect-file-sink.properties 是:

name=local-file-sink
connector.class=FileStreamSink
tasks.max=1
file=test.sink.txt
topics=connect-test

以及 config/connect-file-sink2.properties 是:

name=local-file-sink2
connector.class=FileStreamSink
tasks.max=1
file=test.sink.txt2
topics=connect-test
bvpmtnay

bvpmtnay2#

connect-standalone 除一个辅助进程属性文件外,已获取一个或多个连接器属性文件。
或者你可以跑 connect-distributed ,因为这意味着它是一个长时间运行的服务,所以在默认情况下,您可以将任意多个json配置发布到端口8083

相关问题