下面是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()不应传递null给Deserializers
[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 瞬时失败
您好,请问一下kafka0.10.XX的版本中比较稳定的是哪个,准备升级一下公司的kafka,使用新增的时间戳索引功能
那建议你使用最新的,每一次更新,修复的bug还是很客观的。目前基础功能都是没问题的。额外的stream,connect用新不用旧。
您这个时间戳索引功能怎么用?可以根据时间戳消费吗?
你好,我想问下能否做到kafka 0.8到0.10的无停升级呢。
可以做到,关键是这个“inter.broker.protocol.version”配置,你可以在本地环境测试一下。
ok。我试试。有问题再请教。
大神,你好,我升级的过程遇到了一个问题,发了个kafka问答帖子不知道咋@你了,我想问下按照官网的升级步骤是不是得重启broker两次:第一次把inter.broker.protocol.version设置为当前版本,第二次把inter.broker.protocol.version设置为0.10.1.1。直接一步设置为0.10.1.1不行好像
已回复,发的问题都会邮件通知我,我会看到的。