swoole/phpkafka issues and pull requests

#105 - KafkaErrorException: The server experienced an unexpected error when processing the request

Issue - State: open - Opened by rodrifarias 2 months ago

#104 - 在心跳处理,增加链接重连

Pull Request - State: open - Opened by tw2066 4 months ago

#103 - fix(inifinty-loop): updateMetadata avoid infinity-loop

Pull Request - State: closed - Opened by Lupennat 9 months ago

#102 - feat(sasl): improve sasl interface

Pull Request - State: open - Opened by Lupennat 9 months ago

#101 - feat(sasl): improve sasl interface

Pull Request - State: closed - Opened by Lupennat 9 months ago

#100 - Fix: Exception: setTopicName(): Argument #1 ($topicName) must be of type string, int given

Pull Request - State: open - Opened by info2soft 9 months ago

#99 - 消费kafka数据每隔一小时出现内存溢出问题

Issue - State: open - Opened by Drogenwei about 1 year ago - 1 comment

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

Pull Request - State: open - Opened by wuxi889 over 1 year ago - 6 comments

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

Issue - State: open - Opened by devin515 over 1 year ago - 1 comment

#96 - Fix: Timer::tick callback throw exception cause process exit

Pull Request - State: closed - Opened by szutoutou almost 2 years ago - 1 comment

#95 - Random "Unexpected EOF while reading 4 bytes from stream (no data)"

Issue - State: closed - Opened by Jeckerson almost 2 years ago - 1 comment

#94 - hyperf 接入kafka后遇到问题

Issue - State: closed - Opened by 18767156402 almost 2 years ago - 1 comment

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

Issue - State: open - Opened by crazyfd almost 2 years ago - 1 comment

#92 - [Warning] [82] The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id.

Issue - State: open - Opened by wuxi889 almost 2 years ago

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

Pull Request - State: open - Opened by Anoxia almost 2 years ago - 6 comments

#90 - 对消费者指定分区没法操作

Issue - State: open - Opened by yyforeveryl about 2 years ago

#89 - Getting SocketException while producing an event to Kafka Topic

Issue - State: open - Opened by karunk-hq about 2 years ago

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

Issue - State: open - Opened by shuaiki about 2 years ago - 1 comment

#87 - Fix: repair when socket miss reload kafka client with error code [10753] Unknown(10753)

Pull Request - State: closed - Opened by dygin over 2 years ago - 5 comments

#86 - [10753] Unknown(10753) 错误

Issue - State: closed - Opened by dygin over 2 years ago - 1 comment

#85 - Fix stream error

Pull Request - State: closed - Opened by huangdijia over 2 years ago

#84 - Fixed bug that consume slowly when some brokers don't have messages.

Pull Request - State: closed - Opened by limingxinleo over 2 years ago

#83 - 生产者每次重启后持续十几分钟后就会报错：Could not connect to tcp://hadoop2:9092 (Address not available [99])

Issue - State: closed - Opened by 18310691938 over 2 years ago

#82 - Added timer interface to allow developers to rewrite heartbeat.

Pull Request - State: closed - Opened by huangdijia over 2 years ago - 1 comment

#81 - Fix errors in non-swoole environments

Pull Request - State: closed - Opened by huangdijia over 2 years ago - 1 comment

#80 - 当向一个不存在的 topic 生产消息时导致无限循环最后内存溢出

Issue - State: open - Opened by xingcy08 over 2 years ago - 4 comments

#79 - Fixed bug that process broken when recv failed.

Pull Request - State: closed - Opened by limingxinleo over 2 years ago

#78 - Close channels when close socket.

Pull Request - State: closed - Opened by limingxinleo over 2 years ago

#77 - 修复 producer 报错 Could not recv data from stream 和 producer 死循环

Pull Request - State: closed - Opened by 18310691938 over 2 years ago - 2 comments

#76 - 支持设置producer端参数么

Issue - State: open - Opened by nazrydirunn over 2 years ago

#75 - 消费进程执行一段时间后就出错重启

Issue - State: closed - Opened by SaneHe almost 3 years ago - 4 comments

#74 - Adds support to AWS MSK IAM auth method

Pull Request - State: open - Opened by valmoz almost 3 years ago - 1 comment

#73 - Authentication using the SCRAM-SHA-512 mechanism

Issue - State: closed - Opened by Rishat7c almost 3 years ago - 3 comments

#72 - updateApiVersions 报错 [ERROR] [10753] Unknown[385]

Issue - State: open - Opened by bearzlh almost 3 years ago - 3 comments

#71 - Support SASL AWS_MSK_IAM auth method

Issue - State: closed - Opened by valmoz almost 3 years ago - 2 comments

#70 - Invalid length 352518912 given, it should be lesser than or equals to 5242880

Issue - State: open - Opened by avehub almost 3 years ago - 1 comment

#69 - 在swoole服务中, kafka生产者每过一段时间就报错

Issue - State: open - Opened by insomniazz about 3 years ago - 5 comments

#68 - 我配置bootstrap_servers为内网地址的时候发现链接地址被重置为了 127.0.0.1

Issue - State: closed - Opened by k0spider about 3 years ago - 1 comment

#67 - 请教如何投递延迟任务

Issue - State: open - Opened by huangdijia about 3 years ago

#66 - Int32::unpack() must be of the type int, null returned

Issue - State: closed - Opened by lipin about 3 years ago - 1 comment

#65 - fix: 🐛 swoole client

Pull Request - State: open - Opened by chunhei2008 over 3 years ago

#64 - 设置了exception callback 可能会死循环

Issue - State: open - Opened by chunhei2008 over 3 years ago - 2 comments

#63 - 如何设置auto.offset.reset值

Issue - State: open - Opened by luxin88 over 3 years ago - 2 comments

#62 - minBytes和maxBytes未生效

Issue - State: open - Opened by djwjiawei over 3 years ago - 1 comment

#61 - Support for RedPanda?

Issue - State: open - Opened by slushpuppy over 3 years ago

#60 - 消费者过段时间就报错

Issue - State: closed - Opened by CXW0504 over 3 years ago - 7 comments
Labels: question

#59 - Fix compatibility with PHP 8.1

Pull Request - State: closed - Opened by Yurunsoft over 3 years ago

#58 - Optimize socket close and reconnect

Pull Request - State: closed - Opened by Yurunsoft almost 4 years ago

#57 - 能否返回Producer的调用结果

Issue - State: closed - Opened by warshipJian almost 4 years ago - 1 comment
Labels: question

#56 - 在swoole服务中, kafka生产数据报错

Issue - State: closed - Opened by davisphper almost 4 years ago - 5 comments
Labels: question

#55 - Producer send with header support key-value and RecordHeader

Pull Request - State: closed - Opened by Yurunsoft almost 4 years ago

#54 - 不能获取到Header

Issue - State: closed - Opened by tw2066 almost 4 years ago - 8 comments
Labels: bug, enhancement

#53 - Fatal error: Uncaught longlang\phpkafka\Exception\KafkaErrorException

Issue - State: closed - Opened by dmtnewton almost 4 years ago - 6 comments
Labels: question

#52 - 一个消费者组下两个消费者，只有一个能消费消息

Issue - State: closed - Opened by RickLwy almost 4 years ago - 4 comments
Labels: question

#51 - Sasl 相关的代码现在composer的包无法拉取到

Issue - State: closed - Opened by jackwangshukai almost 4 years ago - 2 comments
Labels: question

#50 - support ssl

Pull Request - State: closed - Opened by qiqizjl almost 4 years ago

#49 - 在socket被断开的时候，可不可以支持broker的socket断线重连

Issue - State: closed - Opened by djwjiawei almost 4 years ago - 1 comment
Labels: enhancement

#48 - 不支持一次消费多条消息么

Issue - State: open - Opened by xiaobingge almost 4 years ago - 3 comments
Labels: question

#47 - support sasl authentication

Pull Request - State: closed - Opened by qiqizjl almost 4 years ago - 7 comments

#46 - 配置新起的消费者组配置从头消费还是从最新的消息开始消费

Issue - State: open - Opened by djwjiawei almost 4 years ago
Labels: enhancement

#45 - Fix #44

Pull Request - State: closed - Opened by Yurunsoft almost 4 years ago

#44 - 当OFFSET_OUT_OF_RANGE时，调用ListOffsetRequest时 currentLeaderEpoch没有设定，导致响应的数据是错的

Issue - State: closed - Opened by djwjiawei almost 4 years ago - 1 comment
Labels: bug

#43 - Throw NoAliveBrokerException when no brokers are available.

Pull Request - State: closed - Opened by limingxinleo about 4 years ago - 1 comment

#42 - Acks设置为0时，会重复插入4条完全相同的数据

Issue - State: closed - Opened by xiaoguo0426 about 4 years ago - 1 comment
Labels: bug

#41 - 「Suggestion」brokers 设置为 null

Issue - State: closed - Opened by yansongda about 4 years ago - 1 comment
Labels: enhancement

#40 - phpkafka的topic不支持正则？

Issue - State: open - Opened by waytoviva about 4 years ago - 1 comment
Labels: enhancement

#39 - 只能连本机的9092端口,连接远程会提示Could not connect to tcp://localhost:9092

Issue - State: closed - Opened by xilin693 about 4 years ago - 4 comments
Labels: question

#38 - updateBrokers方法bug

Issue - State: closed - Opened by wuxian12 about 4 years ago
Labels: bug

#37 - 请问下有实现队列监控或者说有计划支持么？

Issue - State: closed - Opened by BinZhiZhu over 4 years ago - 1 comment
Labels: question

#36 - Update ISSUE_TEMPLATE

Pull Request - State: closed - Opened by sy-records over 4 years ago - 2 comments

#35 - 报错信息

Issue - State: closed - Opened by susueoe over 4 years ago - 1 comment

#34 - SwooleSocket报错

Issue - State: closed - Opened by susueoe over 4 years ago - 1 comment
Labels: question

#33 - 组件中抛出异常 RuntimeException: Partition 0 doses not exists(0)

Issue - State: closed - Opened by suibianmzl over 4 years ago - 6 comments
Labels: question

#32 - fix: ConsumerConfig getBroker and setBroker

Pull Request - State: closed - Opened by PandaLIU-1111 over 4 years ago - 1 comment

#31 - The requested offset is not within the range of offsets maintained by the server

Issue - State: closed - Opened by Dawnry over 4 years ago - 9 comments
Labels: bug

#30 - 同时启动两个消费者，只有一个能成功拉取到消息。

Issue - State: closed - Opened by 854991114 over 4 years ago - 1 comment
Labels: bug

#29 - Add phpstan

Pull Request - State: closed - Opened by Yurunsoft over 4 years ago

#28 - Add Coding Standards

Pull Request - State: closed - Opened by Yurunsoft over 4 years ago

#27 - For requests intended only for the leader

Issue - State: closed - Opened by susueoe over 4 years ago - 1 comment

#26 - 请问什么原因导致了fetchMessages 中 $currentList 为空

Issue - State: closed - Opened by suibianmzl over 4 years ago - 4 comments
Labels: question

#25 - 创建主题失败

Issue - State: closed - Opened by fengxin2017 over 4 years ago

#24 - Fix problems with multiple brokers

Pull Request - State: closed - Opened by Yurunsoft over 4 years ago

#23 - Update ConsumeMessage.php

Pull Request - State: closed - Opened by PandaLIU-1111 over 4 years ago

#22 - fix: dead loop

Pull Request - State: closed - Opened by Reasno over 4 years ago - 3 comments

#21 - Add English documentation.

Pull Request - State: closed - Opened by reneeteng over 4 years ago

#20 - fix: $correlationId not found

Pull Request - State: closed - Opened by Reasno over 4 years ago - 2 comments

#19 - $correlationId 在异常时并不一定存在

Pull Request - State: closed - Opened by Reasno over 4 years ago - 1 comment

#18 - Fix wrong producer brokerId #15

Pull Request - State: closed - Opened by Yurunsoft over 4 years ago

#17 - Fix failed to catch recv coroutine exception #16

Pull Request - State: closed - Opened by Yurunsoft over 4 years ago

#16 - socket关闭时程序异常退出。

Issue - State: closed - Opened by Reasno over 4 years ago
Labels: bug, enhancement

#15 - 作为一个生产者，如何确定正确的brokerId？

Issue - State: closed - Opened by Reasno over 4 years ago - 1 comment
Labels: bug, enhancement

#14 - 多个borker该怎么配consumer？

Issue - State: closed - Opened by jasonwwl over 4 years ago - 1 comment
Labels: question

#13 - Idea: rename bootstrapServer to bootstrapServers and move to common configs

Issue - State: closed - Opened by leocavalcante over 4 years ago
Labels: enhancement

#12 - fix: use coordinator

Pull Request - State: closed - Opened by leocavalcante over 4 years ago - 2 comments

#11 - fix: get client

Pull Request - State: closed - Opened by leocavalcante over 4 years ago

#10 - fix: set brokers

Pull Request - State: closed - Opened by leocavalcante over 4 years ago

#9 - 现在能支持消费者 rebalance 时，会自动处理吗，还是需要自己处理

Issue - State: closed - Opened by PandaLIU-1111 over 4 years ago - 1 comment
Labels: question

#8 - updated CommonConfig.php

Pull Request - State: closed - Opened by PandaLIU-1111 over 4 years ago

#7 - 增加auto create topic功能

Issue - State: closed - Opened by amuluowin over 4 years ago
Labels: enhancement

#6 - 关于消费者使用建议

Issue - State: closed - Opened by a53abc over 4 years ago - 1 comment
Labels: enhancement

GitHub / swoole/phpkafka issues and pull requests