Uncaught longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member. #88
Description
-
你遇到了什么问题？
我使用的是php-fpm , 我手动开了三个文件分别消费数据,昨天开始执行,今天过来发现出现以下报错 三个都是
Uncaught longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member. -
Kafka 环境是自建还是云服务？
没装kafka环境,只使用了kafka的消费,消费第三方接口的数据 -
请执行下面的命令获取环境信息。
php -v & php --ri swoole & composer info | grep longlang/phpkafka
# 粘贴到这里
PHP 8.0.20 (cli) (built: Mar 2 2023 12:08:41) ( NTS )
"longlang/phpkafka": "^1.2"
- 提供最小可复现代码：
// 你的代码
// 第三方接口的东西不方便提供
$config = new ConsumerConfig();
$config->setBroker('');
$config->setTopic(''); // 主题名称
$config->setGroupId(''); // 分组ID
$config->setGroupInstanceId('1'); // 三个文件分别是 1 2 3
$config->setSasl([
"type"=>\longlang\phpkafka\Sasl\PlainSasl::class,
"username"=>"",
"password"=>""
]);
while(true) {
$message = $consumer->consume();
if($message) {
var_dump($message->getKey() . ':' . $message->getValue());
$consumer->ack($message); // 手动提交
}
sleep(1);
}