当前位置: 首页 > 面试题库 >

Kafka 创建 Topic 时如何将分区放置到不同的 Broker 中?

太叔昊穹
2023-03-14
本文向大家介绍Kafka 创建 Topic 时如何将分区放置到不同的 Broker 中?相关面试题,主要包含被问及Kafka 创建 Topic 时如何将分区放置到不同的 Broker 中?时的应答技巧和注意事项,需要的朋友参考一下

副本因子不能大于 Broker 的个数;

第一个分区(编号为 0)的第一个副本放置位置是随机从 brokerList 选择的;

其他分区的第一个副本放置位置相对于第 0 个分区依次往后移。也就是如果我们有 5 个

Broker,5 个分区,假设第一个分区放在第四个 Broker 上,那么第二个分区将会放在第五

个 Broker 上;第三个分区将会放在第一个 Broker 上;第四个分区将会放在第二个

Broker 上,依次类推;

剩余的副本相对于第一个副本放置位置其实是由 nextReplicaShift 决定的,而这个数也是

随机产生的

 类似资料:
  • 本文向大家介绍Kafka创建Topic时如何将分区放置到不同的Broker中相关面试题,主要包含被问及Kafka创建Topic时如何将分区放置到不同的Broker中时的应答技巧和注意事项,需要的朋友参考一下 副本因子不能大于 Broker 的个数; 第一个分区(编号为0)的第一个副本放置位置是随机从 选择的; 其他分区的第一个副本放置位置相对于第0个分区依次往后移。也就是如果我们有5个 Broke

  • 本文向大家介绍创建topic时如何选择合适的分区数?相关面试题,主要包含被问及创建topic时如何选择合适的分区数?时的应答技巧和注意事项,需要的朋友参考一下 根据集群的机器数量和需要的吞吐量来决定适合的分区数

  • 我有以下代码: ...原因:java.lang.ClassNotFoundException:com.fasterxml.jackson.databind.jsonNode在java.base/jdk.internal.loader.builtInclassLoader.LoadClass(builtInclassLoader.java:581)在java.base/jdk.internal.lo

  • 我正在测试在一个正在运行的系统中添加Kafka分区,但我不清楚如果您将分区添加到一个现有的主题中,Kafka如何管理现有的数据。 例如: 我有一个主题为的Kafka实例,有一个分区和一个副本。 生产者组开始插入该主题,消费者组开始消费。 我更改主题以添加另一个分区。 在本例中,主题数据发生了什么?是在两个分区之间重新平衡,还是只有新生成的数据才会使用新分区?

  • 这是将Spark dataframe保存为Hive中的动态分区表的后续操作。我试图在答案中使用建议,但无法在Spark 1.6.1中使用 任何推动这一进程的帮助都是感激的。 编辑:还创建了SPARK-14927

  • 主要内容:1 asyncSendMessage异步处理单条消息,2 preSend准备响应命令对象,2.1 msgCheck检查并自动创建topic,3 handlePutMessageResultFuture处理消息存放结果,3.1 handlePutMessageResult处理存放消息的结果,4 总结基于RocketMQ release-4.9.3,深入的介绍了Broker接收消息源码,以及自动创建Topic的源码。 本次我们学习asyncSendMessage方法的整体流程,以及自动创建