phpkafka

phpkafka copied to clipboard

phpkafka的topic不支持正则？

1

* 你遇到了什么问题 topic 含正则表达式 都不能用，显示以下错误， kafka [api]里kafkaConsumer.subscribe 的第一个参数 支持正则模式订阅， ``` Exception 'longlang\phpkafka\Exception\KafkaErrorException' with message '[17] The request attempted to perform an operation on an invalid topic.' in /mnt/d/proj_path/vendor/longlang/phpkafka/src/Protocol/ErrorCode.php:385 Stack trace:...

waytoviva

* 你遇到了什么问题？ * Kafka 环境是自建还是云服务？ 阿里云 kafka 服务 * 请执行下面的命令获取环境信息。 > `php -v & php --ri swoole & composer info | grep longlang/phpkafka` ``` bash-5.0# php -v & php --ri...

SaneHe

Adds support to AWS MSK IAM auth method

1

Related to issue https://github.com/swoole/phpkafka/issues/71

valmoz

updateApiVersions 报错 [ERROR] [10753] Unknown[385]

3

* 你遇到了什么问题？ 报错日志如下，多发于hyperf一段时间无访问时再次访问出错。频繁访问没有报错 PHP Warning: Uninitialized string offset 0 in /www/hyperf-skeleton/vendor/longlang/phpkafka/src/Protocol/Type/UVarInt.php on line 41 Warning: Uninitialized string offset 0 in /www/hyperf-skeleton/vendor/longlang/phpkafka/src/Protocol/Type/UVarInt.php on line 41 [ERROR] [10753] Unknown[385] in /www/hyperf-skeleton/vendor/longlang/phpkafka/src/Protocol/ErrorCode.php [ERROR]...

bearzlh

添加了基于 SCRAM-SHA512 加密方式的连接

6

### Added * 添加了基于 SCRAM-SHA512 加密方式的连接； 前置条件为需要开启 `ssl`，使用时 `config/autoload/kafka.php` 文件的 `sasl` 配置为 ```php ... 'sasl' => [ 'type' => \longlang\phpkafka\Sasl\ScramSha512Sasl::class, 'username' => env('KAFKA_SASL_USERNAME', ''), 'password' => env('KAFKA_SASL_PASSWORD', ''), // 是否验证第二次握手的服务器响应消息的签名...

wuxi889

kafka rejoin时，fetchMessages抛出警告修复方法讨论

1

* 你遇到了什么问题？ 最近在使用kafka时，每次重启服务都会出现非常多warning；之前也有issue提到过#https://github.com/swoole/phpkafka/issues/92 * 个人建议有两种解决方法。 1、heartbeatTimerId为null时，不执行 `fetchMessages` 方法 2、joinGroup时指定默认的memberId：因为group.instance.id只要没有发生变化，没必要每次rejoin都重新生成member.id * 总结 请问这两种方法，哪种更优？或者有没有其他解决方案

devin515

Uninitialized string offset 0[41] in /data/wwwroot/guanwang/vendor/longlang/phpkafka/src/Protocol/Type/UVarInt.php

1

* 你遇到了什么问题？ 队列投递会出现 Uninitialized string offset 0[41] in /data/wwwroot/guanwang/vendor/longlang/phpkafka/src/Protocol/Type/UVarInt.php 错误 * Kafka 环境是自建还是云服务？ 自建kafka * 请执行下面的命令获取环境信息。 > `php -v & php --ri swoole & composer info | grep longlang/phpkafka` ```...

crazyfd

### What problem did you encounter? From time to time `longlang\phpkafka\Exception\SocketException` exception is launched, with "Unexpected EOF while reading 4 bytes from stream (no data)" message. ### Is the Kafka...

Jeckerson

* 你遇到了什么问题？ `[82] The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id.` * Kafka 环境是自建还是云服务？ Aws Kafka(MSK) * 请执行下面的命令获取环境信息。 >...

wuxi889

对于 topic 不存在时获取 meta 信息直接抛出异常(移除重试)

6

当生产者关闭自动创建 topic 参数设置，然后发起投递时会出现获取 topic meta 数据一直重试问题，代码在此陷入递归死循环。基于有问题尽早抛出原则，建议移除 `ErrorCode::UNKNOWN_TOPIC_OR_PARTITION` 这个 case 分支，直接抛出异常。

anoxia