Added
- #5499 Support
enumforhyperf/constants. - #5508 Added
Hyperf\Rpc\Protocol::getNormalizer. - #5509 Auto register
normalizerforjson-rpc. - #5513 Use default normalizer for
rpc-multiplexand useprotocol.normalizerforrpc-server. - #5518 Added
SwooleConnection::getSocketto get swoole response. - #5520 Added
Coroutine::stats()andCoroutine::exists(). - #5525 Added
kafka.default.consume_timeoutto control the consumer for consuming messages. - #5526 Added
Hyperf\Kafka\AbstractConsumer::isEnable()to control the kafka consumer start or not.
Fixed
- #5519 Fixed bug that worker cannot exit caused by kafka
producer->loop(). - #5523 Fixed bug that process stopped when kafka rebalance.
Optimized
- #5510 Allow developers to replace the
normalizerofRPC Clientthemselves. - #5525 Running in an independent coroutine when consume kafka message.
New Contributors
- @lixinhan made their first contribution in #5508
- @ooing made their first contribution in #5512
- @smallsung made their first contribution in #5499
Full Changelog: v3.0.10...v3.0.11