当前位置: 首页 > 知识库问答 >
问题:

具有多个zookeeper配置的kafka

鲍高扬
2023-03-14

对集群设置有点困惑:

>

  • Zookeeper可以通过配置myid(1,2,3...)将其设置为群集例如,在zoo.cfg文件中具有zookeeper1:2888:3888、zookeeper2:2889:3889

    对于Kafka,在server.properties文件中,是否必须为参数zookeeper.connect指定zookeeper服务器的完整列表,还是只要1就足够了?有什么不同吗?我见过一些实践,即使在创建主题时也指定zookeeper服务器的完整列表,例如/opt/kafka/bin/kafka-topics.sh--create--zookeeper x.x.x.x:2181,x.x.x.x:2181,x.x.x.x:2181--replication-factor 1--partitions 1--topic sample_test

    ---生产和DR设置(预计生产和DR之间有很大的延迟)---

    >

  • 假设在生产中有1个Kafka(kafka1)和1个zookeeper服务器(zookeeper1),在DR中有1个Kafka(kafka2)和1个zookeeper服务器(zookeeper2),并将这2个zookeeper组成一个集群;

    运行尿路钳将生产中的数据复制到DR;从uReplicator的例子来看,配置似乎是这样的:kafka1(在生产中)连接到“Zookeeper1:2181/cluster1”,而kafka2(在DR中)连接到“Zookeeper1:2181/cluster2”,“/cluster1”和“/cluster2”是什么意思?对于这个场景,什么是正确的配置,DR中的kafka2连接到Prod中的zookeeper1是什么想法?

  • 共有1个答案

    何安宜
    2023-03-14

    是否必须为参数zookeeper.connect指定zookeeper服务器的完整列表

    最好至少放3或5个。如果你只放一个,然后它就下降了,Kafka很可能不会像预期的那样工作,或者失败。

    在DR中,把这两个动物园管理员组成一个集群

    不过,正如你所指出的

    连接到“zookeeper1:2181/cluster1”,而kafka2(在DR中)连接到“zookeeper1:2181/cluster2”,“/cluster1”、“/cluster2”是什么意思?

    这在动物园管理员中被称为Chroot。把它看作是Zookeeper集群中每个唯一Kafka集群的目录或命名空间。

     类似资料:
    • 在介绍 Biz 生命周期 时,我们提到了有三种方式控制 Biz 的生命周期,并且介绍了使用客户端 API 实现 Biz 的安装、卸载、激活。在这一章节我们介绍如何使用 SOFAArk 提供的动态配置插件,通过 Zookeeper 下发指令,控制 Biz 的生命周期。 引入依赖 SOFAArk 提供了 config-ark-plugin 对接 Zookeeper 配置中心,用于运行时接受配置,达到控

    • 问题内容: 我创建了一个小部件,该小部件显示一个简单的textview,可在配置活动中将其作为Edittext编辑。我将输入的文本与共享的首选项一起保存,因此用户可以点击小部件来编辑文本,并且已经输入的文本将出现在edittextfield中。我的问题是这个。我希望用户能够添加多个窗口小部件,但是当添加第二个窗口小部件时,将从共享首选项中加载与其他窗口小部件中相同的文本。并且,当在widget上被

    • 我试图设置一个独立的Spark2.0服务器来并行处理分析功能。为此,我希望有一个带有多个执行者的工作人员。 我在使用: 独立Spark 2.0 8核 24gig ram Windows server 2008 pyspark(尽管这看起来不相关)

    • 设置 我在端口8082上有一个正在运行的服务器(wilfly swarm,keycloack authenticated),它承载了我的日志功能。我可以通过REST将日志线推送到这个服务器。在幕后,Kafka的制作人正在运行和传播给Kafka的信息。 我在2181口有动物园管理员 我有一个代理在端口9092运行 日志服务器在端口8082上运行 当我试图通过Java生成器(和控制台生成器)生成消息时

    • 我正在通过一些示例学习Akka HTTP堆栈来创建一个新的REST项目(完全非UI)。我一直在使用和扩展Akka HTTP微服务示例,以通过一系列用例和配置来工作,并对Scala和Akka HTTP的良好工作感到惊喜。 目前我有一个这样的配置: 参数只是一个简单的值,其中包含使用、等的典型数据。 有没有什么方法可以在多个Scala文件或某个示例中设置路由? 这可能是我想得太多了,因为我是如何在Ja

    • 所以我的问题是,当我用profile只运行applicaiton时,Spring是否合并了这两个profile,并且我可以在应用程序中看到和?