Skip to content

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

Open
@shuaiki

Description

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions