2018年11月9号,发布Kafka 2.0.1
,以下是2.0.1
版本中解决的JIRA问题的摘要。有关该版本的完整文档,入门指南以及有关该项目的信息,请参阅Kafka官方网站或Kafka中文教程。
有关升级的注意事项:在升级群集之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kafka生产部署的任何其他更改的任何关键信息。
改进
[KAFKA-6914] - Kafka Connect - 插件类应该有一个可以接受父类ClassLoader的构造函数
[KAFKA-7131] - 更新发布脚本生成公告电子邮件文本
[KAFKA-7198] - 增强KafkaStreams启动方法的javadoc文档
[KAFKA-7278] - replaceSegments()不应该在已删除的段列表中调用asyncDeleteSegment()
[KAFKA-7285] - 在EOS下的任务暂停期间,Streams应该对防护更敏感
[KAFKA-7414] - 在副本提取器中超出范围偏移时不要让broker失败
[KAFKA-7454] - 对SslTransportLayer缓冲区使用延迟分配
Bug
[KAFKA-4950] - 迭代Kafka Metrics时出现ConcurrentModificationException
[KAFKA-5891] - 如果消息模式包含时间戳字段,则转换失败
[KAFKA-6648] - Fetcher.getTopicMetadata()应返回每个请求主题的所有分区
[KAFKA-7044] - kafka-consumer-groups.sh描述循环或粘性赋值程序的NullPointerException
[KAFKA-7119] - GSSAPI身份验证失败导致间歇性测试失败
[KAFKA-7128] - 延迟高水位可能导致ISR扩展后提交的数据丢失
[KAFKA-7144] - Kafka Streams没有正确平衡分区分配
[KAFKA-7158] - 使用缓存搜索kafka流状态存储时重复
[KAFKA-7164] - follower应该在每个leder时期变化后截断
[KAFKA-7180] - 在testHWCheckpointWithFailuresSingleLogSegment中,等到server1加入ISR,然后关闭server2
[KAFKA-7192] - 状态存储可以与变更日志失去同步
[KAFKA-7196] - 在每次重新平衡结束时,为已删除的消费者删除心跳延迟操作
[KAFKA-7216] - 从Kafka 1.0环境运行kafka-acls.sh调用目标kafka 1.1.1上运行异常
[KAFKA-7225] - 验证前未调用Kafka Connect ConfigProvider
[KAFKA-7242] - 任务配置中显示外部化机密
[KAFKA-7250] - Kafka-Streams-Scala DSL转换共享变换器实例
[KAFKA-7255] - SimpleAclAuthorizer中的计时问题与并发创建/更新
[KAFKA-7261] - 请求和响应总指标消息字节而不是请求计数
[KAFKA-7280] - 心跳线程中FetchSessionHandler中的ConcurrentModificationException
[KAFKA-7284] - 生产者获得围栏可能会导致Streams关闭
[KAFKA-7287] - 为旧的消费者znode路径设置开放ACL权限
[KAFKA-7296] - 生产者应该在TxnOffsetCommit中处理COORDINATOR_LOADING错误
[KAFKA-7298] - 并发DeleteRecords可能会导致生成者中出现致命的OutOfSequence错误
[KAFKA-7301] - 在Scala DSL中无法解析KTable到KTable连接调用
[KAFKA-7316] - 在KTable.scala中使用filter方法可能会导致StackOverflowError
[KAFKA-7353] - 将日志“this”连接到匿名内部类
[KAFKA-7354] - 修复IdlePercent和NetworkProcessorAvgIdlePercent指标计算
[KAFKA-7369] - 尽可能在 AdminClient.listConsumerGroups 中重试
[KAFKA-7385] - 当使用幂等或事务生产者保留空批处理时,日志清理程序崩溃
[KAFKA-7386] - Streams Scala包装器不应该缓存serdes
[KAFKA-7415] - OffsetsForLeaderEpoch可能会错误地响应未定义的纪元,导致截断到HW
[KAFKA-7434] - 如果转换抛出NPE,DeadLetterQueueReporter会抛出NPE
[KAFKA-7453] - 启用从未选择的连接的空闲到期时间
[KAFKA-7459] - 更新RequestsPerSec指标时的并发错误
[KAFKA-7460] - Connect Values转换器使用错误的日期格式字符串
[KAFKA-7464] - 在broker清理关闭期间无法关闭ReplicaManager
[KAFKA-7467] - 因为controlBatch为空,引发NoSuchElementException异常
[KAFKA-7476] - SchemaProjector未正确处理基于日期的逻辑类型
[KAFKA-7519] - TransactionalManager在事务ID到期期间处于挂起状态的事务ID是不可用的
[KAFKA-7535] - 如果isolation_level是read_committed,KafkaConsumer不会报告记录延迟
任务
[KAFKA-7228] - DeadLetterQueue抛出NullPointerException异常
子任务
[KAFKA-7299] - 批量LeaderAndIsr请求在自动首选leader选举期间