CCMPP

我是新来的。我的项目是Java项目。我通读了pact文档，找到了github项目https://github.com/dius/pact-jvm/tree/master/pact-jvm-consumer-junit，我将其导入到eclipse IDE中。我被困在这里了。1.首先运行哪个测试。ExampleJavaConsumerPactRuleTest还是ExampleJavaConsumerP

当一个新的消费者/borker被添加或下降时，Kafka会触发一个再平衡操作。Kafka是在重新平衡封锁行动。Kafka的消费者是不是在一个再平衡操作正在进行的时候就被封锁了？

本文向大家介绍消费组与分区重平衡相关面试题，主要包含被问及消费组与分区重平衡时的应答技巧和注意事项，需要的朋友参考一下 当有新的消费者加入到消费者组时，原本的分区就需要重新分配；比如一个topic有30个分区，原本只有两个消费者，每人负责15个分区，当新加入一个消费者时，并没有分区可以给他消费，只能是将30个分区重新分配。 每个消费者组都会有一个broker负责协调（称为group coordin

有人能告诉我Kafka消费者的再平衡算法是什么吗？我想了解分区计数和消费者线程是如何影响这一点的。 非常感谢。

当一个组中只有一个消费者，并且认为消费者无法在session.time.out内进行轮询时，将触发重新平衡，但是在这种情况下，组中只有一个消费者，现在假设session.time.out是30秒和消费者民意调查后50秒组协调员将识别消费者后50秒，并允许它提交偏移或协调员将断开消费者和没有偏移得到提交，并将重新平衡消费者与新的消费者标识？如果上次提交的偏移量是345678，在下一次轮询中，它处理了

试图理解Kafka中的消费者群体行为。示例4分区可用。在消费者方面，消费者群体控制着4个消费者。在这种情况下，在消费者组中的4个消费者中，只有一个消费者始终收到消息。其他人总是无所事事。可能的原因是什么？ 是否所有分区都保存相同的消息？或者所有分区都有相同的消息？或者我们可以认为分区不是均匀分布的吗？