Kafka 分区数可以增加或减少吗？为什么？
我们可以使用 bin/kafka-topics.sh 命令对 Kafka 增加 Kafka 的分区数据，但是 Kafka 不支持减少分区数。 Kafka 分区数据不支持减少是由很多原因的，比如减少的分区其数据放到哪里去？是删除，还是保留？删除的话，那么这些没消费的消息不就丢了。如果保留这些消息如何放到其他分区里面？追加到其他分区后面的话那么就破坏了 Kafka 单个分区的有序性。如果要保证删除分区数据插入到其他分区保证有序性，那么实现起来逻辑就会非常复杂。
-
我不确定在进行聚合操作时应该增加还是减少分区数量。假设我正在使用pyspark数据框架。。 我知道行转换通常需要更多的分区。而将数据保存到磁盘通常需要fewere分区。 但是，对于聚合，我不清楚在中做什么？？ 增加分区数的参数：由于我们必须为聚合而洗牌数据，因此您希望洗牌更少的数据，从而增加分区数，以减小分区的大小。 减少分区数量的论点：IT需要大量开销来收集和计算每个分区。因此，太多的分区将导致
-
本文向大家介绍topic的分区数可不可以减少？如果可以怎么减少？如果不可以，那又是为什么？相关面试题，主要包含被问及topic的分区数可不可以减少？如果可以怎么减少？如果不可以，那又是为什么？时的应答技巧和注意事项，需要的朋友参考一下 不可以减少，被删除的分区数据难以处理。
-
我试图理解和之间的区别。 如果我正确理解了这个答案，只能减少dataframe的分区数量，如果我们尝试增加分区数量，那么分区数量将保持不变。 但当我试图执行下面的代码时，我发现了两件事 对于合并的Dataframe，可以增加分区数 对于Rdd，如果Shuffle=false，那么分区的数量不能随着合并而增加。 这是否意味着使用合并数据帧分区可以增加？ 当我执行以下代码时： 我得到以下输出 当我执行
-
本文向大家介绍topic的分区数可不可以增加？如果可以怎么增加？如果不可以，那又是为什么？相关面试题，主要包含被问及topic的分区数可不可以增加？如果可以怎么增加？如果不可以，那又是为什么？时的应答技巧和注意事项，需要的朋友参考一下 可以增加 bin/kafka-topics.sh --zookeeper localhost:2181/kafka --alter --topic topic-co
-
我有一个使用Kafka 1.0作为队列的应用程序。Kafka主题有80个分区和80个正在运行的使用者。（Kafkapython消费者）。 通过运行命令： 我看到其中一个分区被卡在一个偏移位置，并且随着新记录的添加，延迟会不断增加。 上面命令的输出如下所示： 这是什么原因？此外，不需要使用重置偏移量命令重置偏移量，因为可能不会定期手动监视此服务器。 客户端作为Linux m/c中的并行进程在后台运行
-
问题内容： Java为什么要指定覆盖方法的访问说明符可以比覆盖方法允许更多但不能更少的访问？例如，超类中的受保护实例方法可以在子类中公开，但不能私有。 问题答案： 这是OOP中的基本原则：子类是父类的完整实例，因此必须至少提供与父类相同的接口。使受保护的/公共的东西不那么明显将违反这个想法；您可以使子类无法用作父类的实例。