<li> <p> 添加新选项updateConsumerOffsets，当消费者的offset不在Broker的数据范围内，是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项，生产环境不建议。 </p> </li> <li> <p> 添加新选项loadMessageStoresInParallel，是否在启动的时候并行加载数据，提高启动速度，默认为false。 </p> </li> <li> <p> sync协议新增checksum，类似put </p> </li> <li> <p> stats协议新增reset和help命令，分别用于重设实时统计数据和打印帮助信息。 </p> </li> <li> <p> 添加服务端启动时的配置参数校验，帮助检查配置错误。 </p> </li> <li> <p> metaServer.sh新增slave-status命令，用于查看异步复制状态。 </p> </li> <li> <p> 更优雅地关闭服务器，避免数据损坏。 </p> </li> <li> <p> 当服务器端列表变动的时候，尽量避免producer发送消息异常。 </p> </li> <li> <p> 当同步复制的slave服务端无法服务时，master服务器将尽快返回失败异常给producer。 </p> </li> <li> <p> 改进consumer的负载均衡实现，更快速和稳定地实现负载均衡。 </p> </li> <li> <p> 修复producer可能出现的连接内存泄漏。 </p> </li> <li> <p> Java客户端<code>MessageConsumer</code>接口新增<code>setRejectConsumptionHandler</code>方法用于设置拒绝消费处理器。 </p> </li> <li> <p> <code>Message</code>对象新增<code>readOnly</code>属性，可设置消息是否只读。在<code>PartitionSelector</code>的getPartition方法中，消息将强制为只读。 </p> </li> <li> <p> <code>MessageListener</code>接口的<code>recieveMessages</code>方法可抛出<code>InterruptedException</code>的受控异常，响应中断。当中断发生时正在消费的消息将被回滚。 </p> </li> <li> <p> 文档已经更新： <a href="https://github.

<li> <p> 添加新选项updateConsumerOffsets，当消费者的offset不在Broker的数据范围内，是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项，生产环境不建议。 </p> </li> <li> <p> 添加新选项loadMessageStoresInParallel，是否在启动的时候并行加载数据，提高启动速度，默认为false。 </p> </li> <li> <p> sync协议新增checksum，类似put </p> </li> <li> <p> stats协议新增reset和help命令，分别用于重设实时统计数据和打印帮助信息。 </p> </li> <li> <p> 添加服务端启动时的配置参数校验，帮助检查配置错误。 </p> </li> <li> <p> metaServer.sh新增slave-status命令，用于查看异步复制状态。 </p> </li> <li> <p> 更优雅地关闭服务器，避免数据损坏。 </p> </li> <li> <p> 当服务器端列表变动的时候，尽量避免producer发送消息异常。 </p> </li> <li> <p> 当同步复制的slave服务端无法服务时，master服务器将尽快返回失败异常给producer。 </p> </li> <li> <p> 改进consumer的负载均衡实现，更快速和稳定地实现负载均衡。 </p> </li> <li> <p> 修复producer可能出现的连接内存泄漏。 </p> </li> <li> <p> Java客户端<code>MessageConsumer</code>接口新增<code>setRejectConsumptionHandler</code>方法用于设置拒绝消费处理器。 </p> </li> <li> <p> <code>Message</code>对象新增<code>readOnly</code>属性，可设置消息是否只读。在<code>PartitionSelector</code>的getPartition方法中，消息将强制为只读。 </p> </li> <li> <p> <code>MessageListener</code>接口的<code>recieveMessages</code>方法可抛出<code>InterruptedException</code>的受控异常，响应中断。当中断发生时正在消费的消息将被回滚。 </p> </li> <li> <p> 文档已经更新： <a href="https://github.

<li> <p> 添加新选项updateConsumerOffsets，当消费者的offset不在Broker的数据范围内，是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项，生产环境不建议。 </p> </li> <li> <p> 添加新选项loadMessageStoresInParallel，是否在启动的时候并行加载数据，提高启动速度，默认为false。 </p> </li> <li> <p> sync协议新增checksum，类似put </p> </li> <li> <p> stats协议新增reset和help命令，分别用于重设实时统计数据和打印帮助信息。 </p> </li> <li> <p> 添加服务端启动时的配置参数校验，帮助检查配置错误。 </p> </li> <li> <p> metaServer.sh新增slave-status命令，用于查看异步复制状态。 </p> </li> <li> <p> 更优雅地关闭服务器，避免数据损坏。 </p> </li> <li> <p> 当服务器端列表变动的时候，尽量避免producer发送消息异常。 </p> </li> <li> <p> 当同步复制的slave服务端无法服务时，master服务器将尽快返回失败异常给producer。 </p> </li> <li> <p> 改进consumer的负载均衡实现，更快速和稳定地实现负载均衡。 </p> </li> <li> <p> 修复producer可能出现的连接内存泄漏。 </p> </li> <li> <p> Java客户端<code>MessageConsumer</code>接口新增<code>setRejectConsumptionHandler</code>方法用于设置拒绝消费处理器。 </p> </li> <li> <p> <code>Message</code>对象新增<code>readOnly</code>属性，可设置消息是否只读。在<code>PartitionSelector</code>的getPartition方法中，消息将强制为只读。 </p> </li> <li> <p> <code>MessageListener</code>接口的<code>recieveMessages</code>方法可抛出<code>InterruptedException</code>的受控异常，响应中断。当中断发生时正在消费的消息将被回滚。 </p> </li> <li> <p> 文档已经更新： <a href="https://github.

<li> <p> 添加新选项updateConsumerOffsets，当消费者的offset不在Broker的数据范围内，是否强制更新消费者的offset为当前最大offset。默认为false。测试开发环境建议开启此选项，生产环境不建议。 </p> </li> <li> <p> 添加新选项loadMessageStoresInParallel，是否在启动的时候并行加载数据，提高启动速度，默认为false。 </p> </li> <li> <p> sync协议新增checksum，类似put </p> </li> <li> <p> stats协议新增reset和help命令，分别用于重设实时统计数据和打印帮助信息。 </p> </li> <li> <p> 添加服务端启动时的配置参数校验，帮助检查配置错误。 </p> </li> <li> <p> metaServer.sh新增slave-status命令，用于查看异步复制状态。 </p> </li> <li> <p> 更优雅地关闭服务器，避免数据损坏。 </p> </li> <li> <p> 当服务器端列表变动的时候，尽量避免producer发送消息异常。 </p> </li> <li> <p> 当同步复制的slave服务端无法服务时，master服务器将尽快返回失败异常给producer。 </p> </li> <li> <p> 改进consumer的负载均衡实现，更快速和稳定地实现负载均衡。 </p> </li> <li> <p> 修复producer可能出现的连接内存泄漏。 </p> </li> <li> <p> Java客户端<code>MessageConsumer</code>接口新增<code>setRejectConsumptionHandler</code>方法用于设置拒绝消费处理器。 </p> </li> <li> <p> <code>Message</code>对象新增<code>readOnly</code>属性，可设置消息是否只读。在<code>PartitionSelector</code>的getPartition方法中，消息将强制为只读。 </p> </li> <li> <p> <code>MessageListener</code>接口的<code>recieveMessages</code>方法可抛出<code>InterruptedException</code>的受控异常，响应中断。当中断发生时正在消费的消息将被回滚。 </p> </li> <li> <p> 文档已经更新： <a href="https://github.