0

根据以下文档,我正在运行一个 kafka 集群并使用 Mirrormaker 2.0 将其复制到另一个集群:

https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0

具体来说,我正在运行以下命令来启动我的镜像制造商:

./bin/connect-mirror-maker.sh ./config/mirror-maker.properties

我的源集群中有大量数据,并且经常出现超时错误。为此,我想设置以下两个属性:

buffer.bytes (default value 32 MB)
offset.flush.timout.ms (default value 5000)

我试图将这些属性覆盖到我的镜像制造商属性中,但正在选择默认值。关于如何覆盖这些默认值的任何建议?

4

0 回答 0