发布说明 - Kafka - 0.11.0.1版本

半兽人 发表于: 2017-10-07   最后更新时间: 2018-02-27  
  •   1 订阅,2157 游览

Release Notes - Kafka - Version 0.11.0.1

以下是Kafka 0.11.0.1版本中解决的JIRA问题的摘要。有关该版本的完整文档,入门指南以及有关该项目的信息,请参阅Kafka网站。

有关升级的注意事项:在升级群集之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kafka生产部署的任何其他更改的任何关键信息。

最新版本的文档可以在http://kafka.apache.org/documentation.html 找到。

改进

[KAFKA-5242] - max_number _of_retries添加指数的回退策略
[KAFKA-5410] -SinkTask中的Connectorflush()签名中修复taskClass()方法名称
[KAFKA-5485] - Streams不应该暂停任务2次

Bug

[KAFKA-2105] - 客户端中的MetadataRequest上NullPointerException
[KAFKA-4669] - 当NetworkClient.handleCompletedReceives引发异常时,KafkaProducer.flush挂起
[KAFKA-4856] - 从多个线程调用KafkaProducer.close()可能会导致虚假错误
[KAFKA-5152] - Kafka Streams在启动过程中启动关机后仍保持恢复状态
[KAFKA-5167] - 由于LockException,stream任务在重新平衡后被卡住
[KAFKA-5417] - 当SASL/SSL连接同时标记为CONNECTED和DISCONNECTED时,客户端连接状态不一致
[KAFKA-5431] - 由于org.apache.kafka.common.errors.CorruptRecordException引起的LogCleaner停止
[KAFKA-5464] - StreamsKafkaClient不应该使用StreamsConfig.POLL_MS_CONFIG
[KAFKA-5484] - 重构 kafkatest docker 支持
[KAFKA-5506] - bin/kafka-consumer-groups.sh失败的查询offset
[KAFKA-5508] - 更改主题的文档
[KAFKA-5512] - KafkaConsumer:闲置时内存分配率高
[KAFKA-5544] - 删除分区时,应删除LastStableOffsetLag度量
[KAFKA-5556] - KafkaConsumer.commitSync throws IllegalStateException:尝试从未来检索异常
[KAFKA-5567] - 使用转换,主题-分区提交offset应该引用原始主题分区
[KAFKA-5584] - topic的日志大小不支持,大于2GB
[KAFKA-5587] - Processor获取一个未捕获的异常: NullPointerException
[KAFKA-5600] - 导致老的元数据/偏移缓存的组加载回归
[KAFKA-5603] - 关闭僵尸任务时,stream不应该中止事务
[KAFKA-5608] - 系统测试失败由于超时启动Jmx工具
[KAFKA-5610] - KafkaApis.handleWriteTxnMarkerRequest可以在分区移出时返回UNSUPPORTED_FOR_MESSAGE_FORMAT错误
[KAFKA-5611] - 消费者群体中的一个或多个消费者在重新平衡之后停止消费
[KAFKA-5623] - ducktape kafka服务:不要假设服务包含num_nodes
[KAFKA-5630] - 在CorruptRecordException之后,消费者轮询遍历同一条消息
[KAFKA-5634] - 由于OffsetOutOfRangeException,副本抓取线程崩溃
[KAFKA-5643] - 使用_DUCKTAPE_OPTIONS对执行测试没有影响
[KAFKA-5644] - 短暂性测试失败: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime
[KAFKA-5658] - 修复AdminClient请求超时处理错误,导致持续的BrokerNotAvailableExceptions
[KAFKA-5659] - 解决AdminClient#describeConfigs中的错误处理,效率问题
[KAFKA-5700] - 生产者在分批时遗漏了标题信息
[KAFKA-5704] - 自动主题创建会导致老的集群失败
[KAFKA-5717] - 在状态仓库中[streams]值为'null'
[KAFKA-5731] - Connect WorkerSinkTask无序的offset提交可能会导致不一致的状态
[KAFKA-5737] - KafkaAdminClient应为守护线程
[KAFKA-5745] - Partition.makeLeader()应该在成为leader之前将HOW转换为offset元数据
[KAFKA-5747] - 尝试解析空快照文件时,Broker在启动时崩溃
[KAFKA-5752] - 删除topic并重新创建topic将立即删除新topic的timeindex
[KAFKA-5771] - org.apache.kafka.streams.state.internals.Segments#segments方法返回不正确的结果,当段被按顺序添加
[KAFKA-5787] - StoreChangeLogReader需要恢复添加到初始化后的分区
[KAFKA-5818] - KafkaStreams状态传输不正确

测试

[KAFKA-5742] - 支持在系统测试中传递ZK chroot

子任务

[KAFKA-5020] - 更新协议文档以提到的消息格式v2
[KAFKA-5342] - 区分交易生产者的发送失败
[KAFKA-5490] - 在清洁过程中删除应考虑等级消息保留
[KAFKA-5522] - 当按时间戳搜索时,ListOffset应考虑LSO到账户
[KAFKA-5727] - 添加原型项目以及“写入应用程序”Web文档。






发表于: 10月前   最后更新时间: 5月前   游览量:2157
上一条: 发布说明 - Kafka - 0.11.0.0版本
下一条: 发布说明 - Kafka - 1.0.0版本

评论…


  • 问大神一个问题,kafka同一个消费组内的消费者是线程级别还是进程级别啊
    • 消费者的组是一个概念,你运行一个消费者,当然需要新启动一个应用,也就是一个进程。不需要在一个进程内,启动多个消费者。
        大神,怎么感觉你什么都懂,java, linux, spring, cloud, kafka.......没有你不懂的,太厉害了
        大神,
        我用mirrormaker同步的时候发现,消费组的CURRENT-OFFSET 一个分区有unknown 状态,怎么能不换消费组的情况让他消费到


      • 评论…
        • in this conversation
          提问