longlang/phpkafka

What's Changed

• Close channels when close socket. by @limingxinleo in #78
• Fixed bug that process broken when recv failed. by @limingxinleo in #79

Full Changelog: v1.2.1...v1.2.2

Update Log:

Fixed

• Fix compatibility with PHP 8.1 (#59)

Optimization

• Optimize socket close and reconnect (#58)

更新日志：

修复

• 修复 PHP 8.1 兼容性 (#59)

优化

• 优化 Socket 的关闭和重连 (#58)

Update Log:

Enhancement

• Support SASL authentication (#47)

• Support SSL (#50)

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

Fixed

• Fix VarIntCompactArray and consumer not found headers

Optimization

更新日志：

增强

• 支持 SASL (#47)

• 支持 SSL (#50)

• 发布者发送头时，同时支持键值数组和 RecordHeader 数组 (#55)

修复

• 修复 VarIntCompactArray 导致的消费者消费获取不到头的问题

Update Log:

Fixed

• Fix When acks is set to 0, data is inserted repeatedly (#42)

• Fix use currentLeaderEpoch when updateListOffsets (#44)

Optimization

• Throw NoAliveBrokerException when no brokers are available. (#43)

• Optimize (#41)

更新日志：

修复

• 修复当 acks 设为 0 时，重复插入消息的问题 (#42)

• 修复 updateListOffsets() 时使用 currentLeaderEpoch (#44)

优化

• 当没有可用的代理时抛出NoAliveBrokerException (#43)

• 优化 (#41)

Update Log:

Enhancement

• Add produceRetry, produceRetrySleep in ProducerConfig

Fixed

• Fix typo

• Fix array type is null #38

• Fix producing messages to an uncreated topic

更新日志：

增强

• 在 ProducerConfig 中增加了 produceRetry 和 produceRetrySleep

修复

• 修复拼写问题

• 修复数组类型为 null 时返回报错问题

• 修复给未创建的主题生产消息问题

Update Log:

Enhancement

• Add Coding Standards php-cs-fixer

• Add phpstan

• Add minBytes、maxBytes、maxWait in ConsumerConfig

• Add brokers in ConsumerConfig. The broker is alias of brokers now.

• Add ISSUE_TEMPLATE

Optimization

• Optimize Exception message

• Consumer error handling rejoin

Fixed

• Fix a possible error

• Fix RangeAssignor and RoundRobinAssignor

• Fix consumer when after log cleanup

• Fix saveOffsets

更新日志：

增强

• 增加代码标准检测 php-cs-fixer

• 增加静态分析工具 phpstan

• 在 ConsumerConfig 中增加 minBytes、maxBytes、maxWait

• 在 ConsumerConfig 中增加 brokers。broker 现在是 brokers 的别名了

• 增加 issue 提问模版

优化

• 优化异常消息文字

• 部分消费错误时 rejoin()

修复

• 修复一处可能的错误

• 修复 RangeAssignor 和 RoundRobinAssignor

• 修复清理日志后的消费问题

• 修复保存偏移量

Update Log:

Enhancement

• Add exceptionCallback in CommonConfig

• Support producer partition strategy

Optimization

• Add English document

Fixed

• Fix: dead loop (#22)

• Fix ConsumeMessage $value type (#23)

• Fix problems with multiple brokers (#24)

更新日志：

增强

• 在 CommonConfig 中增加了 exceptionCallback

• 支持分区分配策略

优化

• 增加了英文文档说明

修复

• 修复死循环

• 修复 ConsumeMessage $value 的类型

• 修复多 broker 情况下的生产和消费问题