Release v1.2.2

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

v1.2.1

Update Log:

Fixed

• Fix compatibility with PHP 8.1 (#59)

Optimization

• Optimize socket close and reconnect (#58)

---

更新日志：

修复

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

优化

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

v1.2.0

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 导致的消费者消费获取不到头的问题

v1.1.5

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)

v1.1.4

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 时返回报错问题

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

v1.1.3

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

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

• 修复保存偏移量

v1.1.2

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 情况下的生产和消费问题

v1.1.1

增强

• 支持消费者分区分配策略之粘性分配-\longlang\phpkafka\Consumer\Assignor\StickyAssignor
• 消费者现在也会更新 brokers 了（#12）
• 消费者、生产者配置都增加了 bootstrapServers，原 bootstrapServer 作为别名，依然可以使用

优化

• 优化了一些代码

修复

• 修复 ConsumerConfig 中 broker 为数组时的问题（#10）
• 修复 Broker->getClient()（#11）
• 修复 PHP <= 7.3 中使用时，会将 phpunit 也引入进来的问题
• 修复使用对应的 broker 发送分组消息（#12）

v1.1.0

增强

• 支持 PHP 8.0
• 支持自动创建主题
• 支持同时消费多个主题
• 支持消费者分区分配策略

分区分配策略：
范围分配-longlang\phpkafka\Consumer\Assignor\RangeAssignor
轮询分配-\longlang\phpkafka\Consumer\Assignor\RoundRobinAssignor
粘性分配（暂未支持）-\longlang\phpkafka\Consumer\Assignor\StickyAssignor | longlang\phpkafka\Consumer\Assignor\RangeAssignor

优化

• 优化代码

修复

• 修复 RecordBatch
• 修复类型错误 (#8)

不兼容更改

• 废弃 ConsumerConfig 的 partitions 参数，转而使用分配策略
• 手动 ack() 写法更改，请参考文档

v1.0.1

增强

• 支持分组操作重试机制

• 支持偏移操作重试机制

• 支持心跳机制

优化

• Added code for KafkaErrorException (#4) (@limingxinleo)

• 优化代码 (#5) (@PandaLIU-1111)

• 增加测试用例

修复

• 修复消费者逻辑问题 #2

• 修复消费者内存泄漏问题 #3

• 修复消费多个分区时报 crc32 验证错误问题