一个消费者组下两个消费者，只有一个能消费消息

[RickLwy]

• 你遇到了什么问题？

一个消费者组下两个消费者，只有一个能消费消息

• Kafka 环境是自建还是云服务？

docker自建

• 请执行下面的命令获取环境信息。

php -v & php --ri swoole & composer info | grep longlang/phpkafka

# 粘贴到这里
[1] 15367
[2] 15368
Extension 'swoole' not present.
PHP 7.3.0beta1 (cli) (built: Mar 12 2020 12:13:45) ( NTS )
Copyright (c) 1997-2018 The PHP Group
Zend Engine v3.3.0-dev, Copyright (c) 1998-2018 Zend Technologies
Do not run Composer as root/super user! See https://getcomposer.org/root for details
longlang/phpkafka          v1.1.5 A kafka client. Support php-fpm and Swoole.
[1]-  完成                  php -v
[2]+  退出 1                php --ri swoole

• 提供最小可复现代码：

// 你的代码
use longlang\phpkafka\Consumer\ConsumeMessage;
use longlang\phpkafka\Consumer\Consumer;
use longlang\phpkafka\Consumer\ConsumerConfig;
function consume(ConsumeMessage $message)
{
    var_dump($message->getKey() . ':' . $message->getValue());
    // $consumer->ack($message); // autoCommit设为false时，手动提交
}

$rand = rand(1000,9999);

$config = new ConsumerConfig();
$config->setBroker('192.168.1.166:32769');
$config->setTopic('test'); // 主题名称
$config->setGroupId('testGroup'); // 分组ID
$config->setClientId($rand); // 客户端ID，不同的消费者进程请使用不同的设置
$config->setGroupInstanceId($rand); // 分组实例ID，不同的消费者进程请使用不同的设置
$config->setInterval(0.1);
$consumer = new Consumer($config, 'consume');
$consumer->start();

[Yurunsoft]

等一会会自动触发rejoin，默认应该是60秒，那时候就可以消费到了

[RickLwy]

等了10分钟，还是只有一个消费者可以接收到消息，帮我看下是不是我配置的问题，谢谢

[Yurunsoft]

我复制的你的代码，两个都可以消费，只不过有一个消费的数量比较少，这个是正常的，分配算法原因

[RickLwy]

代码没有问题，是我kafka分区数量的问题，谢谢大佬