phpkafka icon indicating copy to clipboard operation
phpkafka copied to clipboard

Uncaught longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member.

Open shuaiki opened this issue 1 year ago • 0 comments

  • 你遇到了什么问题? 我使用的是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);
        } 

shuaiki avatar May 11 '23 01:05 shuaiki