发行说明 - Kafka - 0.10.0.1版本

半兽人 发表于: 2016-09-24   最后更新时间: 2020-08-17 19:20:56  
{{totalSubscript}} 订阅, 6,747 游览

下面是0.10.0.1版本发布解决关于kafka的JIRA问题汇总。发布,指南入口,和有关项目信息的完整文档,请参阅kafka官方,或kafka中文教程

关于升级说明:请在升级你的集群之前仔细阅读此次版本的升级文档。升级还需注意不兼容性,突发性变化,性能变化以及可能影响你的生产部署的重要信息。

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

新特色

[KAFKA-3538] - Producer为stream sink抽象creation/retrieval的单元测试。

改进

[KAFKA-3667] - 改进7.2节的加密和认证:使用SSL来包含正确hostname的验证配置
[KAFKA-3683] - 增加文件描述符建议到ops指南。
[KAFKA-3699] - 更新网站协议页,解释如何使用KIP-35
[KAFKA-3725] - 更新关于XFS的文件材料
[KAFKA-3747] - 当追加批次失败,关闭 `RecordBatch.records` 
[KAFKA-3785] - Fetcher花不必要的时间在metrics记录
[KAFKA-3836] - RocksDBStore.get()不应传递nullDeserializers
[KAFKA-3880] - 不允许加入大小为零的Windows[KAFKA-3922] - AbstractStream增加一个复制构造函数

Bug

[KAFKA-3185] - 允许用户清理内部数据
[KAFKA-3258] - BrokerTopicMetrics删除的主题永远不会删除
[KAFKA-3393] - 更新站点文档和javadoc,基于max.block.ms变化
[KAFKA-3500] - KafkaOffsetBackingStore设置方法需要处理null。
[KAFKA-3718] - 传递所有 KafkaConfig __consumer_offsets配置到OffsetConfig实例化。
[KAFKA-3728] - EndToEndAuthorizationTest offsets_topic配置错误
[KAFKA-3781] - Errors.exceptionName() 抛出NPE
[KAFKA-3782] - kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True 瞬时故障
[KAFKA-3783] - 去年ACL取消对资源的竞争条件失败,出现的异常ZkBadVersion
[KAFKA-3784] - TimeWindows#windowsFor识别错一些windows(如果TimeWindows#advanceBy被使用)。
[KAFKA-3787] - 在镜像制造商保护消息时间戳
[KAFKA-3789] - 升级Snappy,以修复snappy解压错误。
[KAFKA-3802] - 在相同的机器运行多种实例streams应用导致错误。
[KAFKA-3817] - KTableRepartitionMap应该处理null输入
[KAFKA-3830] - getTGT() debug日志暴露机密信息
[KAFKA-3850] - 如果重新平衡或关闭时唤醒,WorkerSinkTask应重试提交。
[KAFKA-3851] - 添加参考重要的installation/upgrade笔记到发布说明。
[KAFKA-3852] - 澄清如何处理消息格式升级,而不造成性能。
[KAFKA-3854] - 随后的正则表达式订阅调用失败
[KAFKA-3855] - TopologyBuilder的Guard竞争条件
[KAFKA-3864] - Kafka Connect Struct.get返回来自Struct非领域模式的defaultValue
[KAFKA-3879] - 当broker已死kill之后,KafkaConsumer启用自动提交卡住。
[KAFKA-3887] - StreamBounceTest.test_bounce和StreamSmokeTest.test_streams失败
[KAFKA-3890] - kafka Streams:任务分配不保持集群重新启动或滚动重新启动。
[KAFKA-3898] - KStream.leftJoin(…)缺少对thisVal的Serde,这会导致在mapvaluees等之后失败。
[KAFKA-3902] - 优化KTable.filter(),以减少不必要的传递
[KAFKA-3915] - 由于消息格式变更,LogCleaner IO缓冲区不考虑潜在大小的差异。
[KAFKA-3924] - 数据丢失是由于停止时LEO比leader的多。
[KAFKA-3933] - Kafka OOM在日志恢复期间泄露本机内存
[KAFKA-3935] - ConnectDistributedTest.test_restart_failed_task.connector_type=sink系统测试失败
[KAFKA-3941] - 避免在InMemoryKeyValueLoggedStore应用驱逐监听器。
[KAFKA-3950] - kafka镜像制作工具不关心白名单选项。
[KAFKA-3952] - 检查分区所有者时VerifyConsumerRebalance 不能成功
[KAFKA-3960] - 在第一次分配之后commited偏Avoid applying eviction listener in InMemoryKeyValueLoggedStore移量没有设置
[KAFKA-3977] - 从KafkaConsumer吃掉消息deserializers引发的异常。
[KAFKA-3983] - 如果SocketServer的Acceptors在登记处登录SocketChannel端口和处理器ID,这样是有益的。
[KAFKA-3996] - ByteBufferMessageSet.writeTo() 应该是非阻塞
[KAFKA-4008] - 模块 "tools" 不应该依赖 "core"
[KAFKA-4018] - Streams 导致老的slf4j-log4j和新版本一起打包

测试

[KAFKA-3863] - connector failure/restart增加系统测试

子任务

[KAFKA-3660] - ControllerBrokerRequestBatch 中的Log异常消息
[KAFKA-3865] - org.apache.kafka.connect.runtime.WorkerSourceTaskTest.testSlowTaskStart中的瞬时故障
[KAFKA-3931] - kafka.api.PlaintextConsumerTest.testPatternUnsubscription 瞬时失败
更新于 2020-08-17
在线,1小时前登录

鹰击长空 6年前

您好,请问一下kafka0.10.XX的版本中比较稳定的是哪个,准备升级一下公司的kafka,使用新增的时间戳索引功能

半兽人 -> 鹰击长空 6年前

那建议你使用最新的,每一次更新,修复的bug还是很客观的。目前基础功能都是没问题的。额外的stream,connect用新不用旧。

您这个时间戳索引功能怎么用?可以根据时间戳消费吗?

雁过留声 7年前

你好,我想问下能否做到kafka 0.8到0.10的无停升级呢。

半兽人 -> 雁过留声 7年前

可以做到,关键是这个“inter.broker.protocol.version”配置,你可以在本地环境测试一下。

雁过留声 -> 半兽人 7年前

ok。我试试。有问题再请教。

雁过留声 -> 半兽人 7年前

大神,你好,我升级的过程遇到了一个问题,发了个kafka问答帖子不知道咋@你了,我想问下按照官网的升级步骤是不是得重启broker两次:第一次把inter.broker.protocol.version设置为当前版本,第二次把inter.broker.protocol.version设置为0.10.1.1。直接一步设置为0.10.1.1不行好像

半兽人 -> 雁过留声 7年前

已回复,发的问题都会邮件通知我,我会看到的。

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章