Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
shuaiki opened this issue May 11, 2023 · 1 comment

Comments

@shuaiki
Copy link

shuaiki commented May 11, 2023

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

Starexz commented Nov 6, 2024

我也遇到这个报错了,怎么解决呢,这个还有人在维护吗

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants