“再平衡”在阿帕奇·Kafka语境中意味着什么？
我还从https://cwiki.apache.org/confluence/display/kafka/kafka+0.9+consumer+rewrite+design上看到了这段话，但我似乎无法理解它，所以如果有人能帮助我理解它，我将不胜感激：
再平衡是这样一个过程：一组使用者实例（属于同一组）协调起来，以拥有该组订阅的主题的一组互斥分区。在使用者组成功的重新平衡操作结束时，所有订阅主题的每个分区都将由该组内的单个使用者实例拥有。再平衡的工作方式如下。每个代理都被选为消费者组子集的协调者。组的协调代理负责协调用户组成员身份更改或订阅主题的分区更改的再平衡操作。它还负责将得到的分区所有权配置传达给正在进行重新平衡操作的组的所有消费者。
共有1个答案
当一个新的使用者加入一个使用者组时，这组使用者会尝试“重新平衡”负载，为每个使用者分配分区。如果使用者集在此分配过程中发生更改，则重新平衡将失败并重试。此设置控制放弃前的最大尝试次数。
用于此操作的命令是：rebalance.max.retries，默认设置为4。
此外，如果下列情况为真，则可能会发生这种情况：
-
我正试图找出这两种设置之间的区别。大小和缓冲区。Kafka制作人的记忆。 据我所知。大小：这是可以发送的批次的最大大小。 文档描述了缓冲区。memory as：生产者可以用来缓冲等待发送的记录的内存字节。 我不明白这两者之间的区别。有人能解释一下吗？ 谢啦
-
我们需要的是直接的API来设置和使用集群消息队列。我们最初的计划是使用Camel在集群JMS或ActiveMQ队列上进行消费/生产。Kafka如何使这项任务变得更容易？在任何一种情况下，应用程序本身都将在WebLogic服务器上运行。 消息传递将是点对点类型，其中有多个相同服务的实例在运行，但根据负载平衡策略，只有一个实例应该处理消息并发出结果。消息队列也是群集的，因此服务实例或队列实例的失败都不
-
Apache Kafka：分布式消息传递系统 Apache Storm：实时消息处理 我们如何在实时数据管道中使用这两种技术来处理事件数据？ 在实时数据管道方面，我觉得两者做的工作是一样的。如何在数据管道上同时使用这两种技术？
-
我想创建一个
-
当我们的kafka主题中有多个分区时，分区重新平衡是一件常见的事情吗？ 这并不一定意味着我们的应用程序存在延迟或问题？ 我一直看到分区被撤销和重新分配的日志。
-
问题内容： 下面是代码片段。 有人可以向我解释@符号在Java中的含义吗？ 问题答案： 这是一个注释。 注释是元数据的一种形式。它们提供的程序数据不属于程序本身。注释对其注释的代码的操作没有直接影响。 注释确实会影响工具和库对待程序的方式，进而会影响正在运行的程序的语义。可以从源文件，类文件中读取注释，也可以在运行时从中读取注释。