发布说明 - Kafka - 0.11.0.0版本

发布时间：6月28号

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

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

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

新功能

[KAFKA-3487] - KIP-146: 在Connect中支持每个连接器/每个任务的类加载器
[KAFKA-4208] - 添加记录标题
[KAFKA-4586] - 在AdminClient中增加 purgeDataBefore() API
[KAFKA-4720] - 增加 KStream.peek(ForeachAction)
[KAFKA-4743] - 增加一个工具，可重置 Consumer Group Offsets
[KAFKA-4881] - 将内部leave.group.on.close配置添加到消费者
[KAFKA-4923] - 添加‘正好一次’ 到 Streams
[KAFKA-5059] - 实现交易协调者
[KAFKA-5192] - 窗口状态仓库的扫描范围

改进

[KAFKA-1449] - 延长线路协议以允许CRC32C
[KAFKA-2358] - 集群收集返回方法不应返回null
[KAFKA-2955] - 在kafka-console-producer中添加提示
[KAFKA-3714] - 允许用户更多地访问注册自定义流指标
[KAFKA-3878] - broker重新连接尝试的回退指数（KIP-144）
[KAFKA-3989] - Benchmarks增加JMH模块
[KAFKA-3995] - 拆分ProducerBatch并在收到RecordTooLargeException时重新发送
[KAFKA-4144] - 允许每个stream/table时间戳提取器
[KAFKA-4195] - 支持按要求调节速度
[KAFKA-4266] - 复制配额测试：确保ZK在测试开始之前更新
[KAFKA-4276] - 连接器属性配置文件中的REST配置不可见
[KAFKA-4291] - TopicComman --describe 显示被标记为删除的主题不可复制（KIP-137）
[KAFKA-4317] - RocksDB检查点文件在`kill -9`后的丢失
[KAFKA-4613] - 以连接和聚合的方式处理空键记录
[KAFKA-4636] - 每个监听器安全设置覆盖（KIP-103）
[KAFKA-4684] - Kafka在Windows Box中不提供kafka-configs.bat
[KAFKA-4702] - Parametrize流式运行扩展基准
[KAFKA-4709] - Struct.validate()的错误消息应该包含违规字段的名称。
[KAFKA-4722] - 将application.id添加到StreamThread名称
[KAFKA-4733] - 改善流量重置工具控制台输出
[KAFKA-4769] - 添加浮点序列化，解串器，serde
[KAFKA-4772] - 利用#peek实现#print()和其他方法
[KAFKA-4773] - Kafka构建应运行findbugs
[KAFKA-4774] - 内部类不需要引用外部类，应该是静态的。
[KAFKA-4775] - 在kafka工具中修复findbugs警告
[KAFKA-4839] - 从轮询中为所有分配的分区抛出NoOffsetForPartitionException一次
[KAFKA-4843] - 流循环调度程序效率低下
[KAFKA-4922] - 修复客户端和连接中的几个FindBugs警告
[KAFKA-4943] - 使用Zookeeper ACL更好地保护SCRAM秘密
[KAFKA-4965] - 在KafkaStreams中将internal.leave.group.on.close设置为false
[KAFKA-4982] - 将侦听器标签添加到socket-server-metrics.connection-... metrics（KIP-136）
[KAFKA-5036] - 跟踪 kip-101
[KAFKA-5052] - 异步偏移的提交失败时，我们不应该传递给 RetriableCommitFailedException底层异常。
[KAFKA-5068] - 在运行perf测试后，可以选择打印的指标
[KAFKA-5091] - ReassignPartitionsCommand应该防止空副本任务列表
[KAFKA-5094] - 审查SCRAM配置更改日志
[KAFKA-5104] - DumpLogSegments不应该使用“rw”打开索引文件
[KAFKA-5108] - 添加对读取PID快照文件到DumpLogSegments的支持
[KAFKA-5111] - 优化内部 Task APIs
[KAFKA-5112] - 主干兼容性测试应该测试0.10.2
[KAFKA-5118] - 改进了kafka在data.dirs中使用非kafka数据失败启动的消息
[KAFKA-5137] - 控制关闭超时消息的改进
[KAFKA-5161] - 重新分配分区，以检查在集群中是否存在此ID的broker
[KAFKA-5166] - 添加选项“dry run”到Streams应用程序重置工具
[KAFKA-5176] - AdminClient: 添加控制和clusterId方法到 DescribeClusterResults
[KAFKA-5194] - KIP-153: 只包含BytesOutPerSec度量的客户端流量
[KAFKA-5210] - 应用程序重置工具不需要寻找内部topic
[KAFKA-5218] - 新的短序列化器，反序列化器，serde
[KAFKA-5257] - 改变默认的unclean.leader.election.enabled 值，从Ture改为Flase。
[KAFKA-5277] - 粘贴的Assignor不应该缓存经过计算的赋值(kip-54跟踪)
[KAFKA-5311] - 支持在Kafka流中扩展的反序列化器
[KAFKA-5333] - 删除Broker ACL资源类型
[KAFKA-5405] - 请求日志应该记录限制时间
[KAFKA-5411] - 为AdminClient生成javadoc，并在文档中显示configs
[KAFKA-5446] - 在log.error使用流显示了烦人的括号。

Bug

[KAFKA-977] - 实现generation/term每个leader，以使得消息正确一致。
[KAFKA-1211] - 在purgatory中使用ack > 1进行生产请求，直到副本的HW大于生产偏移量(kip-101)
[KAFKA-2000] - 一旦topic被删除，则删除kafka的消费者偏移量
[KAFKA-2818] - 在强制退出时清除控制器对象
[KAFKA-2857] - 当offset topic已经创建，描述一个不存在的group时，ConsumerGroupCommand 抛出 GroupCoordinatorNotAvailableException 
[KAFKA-3070] - SASL单元测试无法在IBM JDK运行
[KAFKA-3123] - 如果offset已经超出范围，追随者broker无法创建。
[KAFKA-3353] - 删除已启用的生产者配置。
[KAFKA-3754] - kafka默认 -xloggc设置应该包括GC日志旋转标志
[KAFKA-3835] - Streams为每个发送创建两个ProducerRecords（通过RecordCollector）
[KAFKA-3919] - 由于日志中非单调增加的偏移量，broker强制关闭后无法启动
[KAFKA-3940] - 日志应该检查dir.mkdirs()的返回值
[KAFKA-3959] - KIP-115：__consumer_offsets 启动时副本数不正确
[KAFKA-3982] - 在消费者控台，发布的处理消费者属性的顺序
[KAFKA-4039] - 退出策略：使用异常而不是内步调用exit/halt
[KAFKA-4059] - 文档仍然指AsyncProducer和SyncProducer
[KAFKA-4343] - KIP-151: 连接REST API应公开每个连接器是源还是接收器
[KAFKA-4408] - KTable不能在Kafka 0.10.1.0版本的ProcessorTopologyTestDriver运行。
[KAFKA-4459] - rat证书在jenkins没有运行
[KAFKA-4461] - 当使用ProcessorTopologyTestDriver时，map和.groupByKey的组合不会产生任何结果
[KAFKA-4484] - 在RocksDB上为内存使用设置更保守的默认值
[KAFKA-4494] - KStreams应用程序严重的启动延迟
[KAFKA-4525] - Kafka不需要SSL信任仓库密码
[KAFKA-4564] - 当目标broker在配置中关闭或配置错误时，Streams应该快速的失败
[KAFKA-4567] - Connect Producer和Consumer忽略了worker配置的ssl参数
[KAFKA-4594] - 注解集成测试，并提供gradle构建目标来运行测试子集
[KAFKA-4595] - 当broker更改监听事件触发器为已宕的broker时，控制器发送线程不能停止
[KAFKA-4603] - shell的参数在doc错误和命令解析错误
[KAFKA-4607] - Kafka Streams允许你为内部topic名称提供非法字符的字符串
[KAFKA-4617] - gradle生成的核心eclipse项目有不正确的源文件夹结构
[KAFKA-4631] - 为未知订阅topic更频繁地刷新消费者元数据
[KAFKA-4667] - KIP-154: Connect 应该创建内部的topics
[KAFKA-4671] - 修复流窗口保留策略
[KAFKA-4672] - KIP-100 在某些情况下，api更改会破坏Java 8 lambda表达式
[KAFKA-4673] - Python VerifiableConsumer服务对于event_handlers有线程安全问题
[KAFKA-4677] - 避免在重新平衡期间不必要的任务在线程之间移动
[KAFKA-4689] - OffsetValidationTest使用“当前位置大于已消费的记录总数”进行验证失败
[KAFKA-4700] - StreamsKafkaClient 下调安全配置
[KAFKA-4708] - 修复BrokerApiVersionsCommandTest.checkBrokerApiVersionCommandOutput中的短暂故障
[KAFKA-4714] - 实现剩余的KIP-66 SMT
[KAFKA-4716] - 修复内部topic准备就绪的重新检查逻辑
[KAFKA-4717] - 连接jar缺少许可证/通知文件
[KAFKA-4719] - 在OffsetValidationTest.test_broker_failure的超时等待消费
[KAFKA-4724] - 清理状态目录可能会删除即将被另一个线程使用
[KAFKA-4728] - KafkaConsumer#commitSync关闭输入
[KAFKA-4735] - 修复MM关机期间的死锁问题
[KAFKA-4738] - 删除通用类的ClientState类
[KAFKA-4741] - RecordAccumulator.append中的内存泄漏
[KAFKA-4744] - Streams_bounce测试偶尔失败
[KAFKA-4749] - 修正join-time-max和sync-time-max MeasurableStat类型
[KAFKA-4752] - Stream简单基准 MB/秒计算对于加入操作是不正确的
[KAFKA-4755] - SimpleBenchmark测试失败的流
[KAFKA-4757] - 改进NetworkClient跟踪日志记录请求详细信息
[KAFKA-4758] - 连接WorkerSinkTask缺少NO_TIMESTAMP的检查
[KAFKA-4765] - org.apache.kafka.clients.producer.KafkaProducerTest＃testConstructorFailureCloseResource和类似测试在某些系统上失败（127.0.53.53碰撞警告）
[KAFKA-4776] - 对不正确形成的压缩消息集执行优雅处理
[KAFKA-4777] - Kafka客户端心跳线程使用所有的cpu。
[KAFKA-4779] - kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py的故障
[KAFKA-4783] - KIP-128: Blackbox或通过转换器或ByteArrayConverter进行连接
[KAFKA-4788] - 当topic没有配置'segment.bytes'时，Broker级别配置'log.segment.bytes'不会使用。
[KAFKA-4789] - ProcessorTopologyTestDriver不将提取的时间戳转发到内部主题
[KAFKA-4790] - 磁盘满了之后，kafka无法恢复
[KAFKA-4791] - Kafka Streams - 在源上使用通配符topic时无法添加状态存储
[KAFKA-4796] - 在Kafka Java客户端修复一些findbugs警告
[KAFKA-4800] - 流状态转换ASCII图需要修复和抛光
[KAFKA-4806] - KafkaConsumer: ConsumerConfig获取记录两次。
[KAFKA-4809] - docker / run_tests.sh应该将/opt/kafka-dev设置为源目录
[KAFKA-4810] - 如果它们被设置为相同的值，那么SchemaBuilder对于检查这些字段是未设置的应该更加宽松
[KAFKA-4811] - 由于现有指标，ReplicaFetchThread可能无法创建。
[KAFKA-4814] - ZookeeperLeaderElector 不遵守 zookeeper.set.acl
[KAFKA-4826] - 修复一些在Kafka Streams的findbugs告警。
[KAFKA-4828] - ProcessorTopologyTestDriver当使用.through()时，无法工作
[KAFKA-4837] - Connector插件中的配置验证需要与规范和简单的类名进行比较
[KAFKA-4841] - NetworkClient应该仅在尝试连接后才考虑连接失败
[KAFKA-4848] - 流线程进入死锁状态，同时试图获得rockdb锁在retryWithBackoff
[KAFKA-4851] - SessionStore.fetch(key)的性能瓶颈
[KAFKA-4855] - Struct SchemaBuilder不应该允许重复的字段。
[KAFKA-4863] - 查询窗口存储可能会返回不需要的密钥
[KAFKA-4864] - Kafka Secure Migrator工具不保护所有节点
[KAFKA-4866] - Kafka控制台消费者属性被忽略
[KAFKA-4878] - Kafka Connect不记录连接器配置错误
[KAFKA-4885] - processstreamwithcachedstatestore和其他流基准偶发性故障
[KAFKA-4891] - kafka.request.logger TRACE 回退
[KAFKA-4894] - 修复findbugs“使用默认字符集”警告
[KAFKA-4895] - 修复findbugs“格式字符串应该使用％n而不是\ n”在工具中
[KAFKA-4899] - 在kafka核心修复findbugs警告
[KAFKA-4901] - 使ProduceRequest线程安全
[KAFKA-4902] - Utils＃delete应该正确处理I/O错误和符号链接
[KAFKA-4903] - 为读取Shell命令stdout删除未使用的代码并添加单元测试
[KAFKA-4916] - 添加流测试与Broker失败
[KAFKA-4919] - 当处理器关闭时，不得关闭仓库文档
[KAFKA-4924] - 修复在Kafka-Connect-API中的findbugs警告
[KAFKA-4925] - 向初始的消费者群体重新平衡添加可配置的延迟
[KAFKA-4927] - 当使用 KStream.to() sinks时，KStreamsTestDriver和NPE会失败
[KAFKA-4929] - 转换键/值类型引用应该是类name()，而不是canonicalName（）
[KAFKA-4937] - 在Streams的StoreChangelogReader重置批次
[KAFKA-4942] - Kafka Connect: Offset提交超过预期时间
[KAFKA-4944] - 在Stream示例中修复“未读字段”的findbugs警告
[KAFKA-4945] - 在jmh-benchmark中过滤findbugs关于机器生成代码的警告
[KAFKA-4959] - 删除控制器并发访问非线程安全网络客户端，选择器和SSLEngine
[KAFKA-4964] - 删除kafka前缀的密钥库和信任库文件的名称，这样做命名更合适
[KAFKA-4977] - kafka-connect: 修复connect/runtime中的findbugs问题
[KAFKA-4980] - testReprocessingFromScratch测试失败
[KAFKA-4993] - 修复在kafka-clients的findbugs警告
[KAFKA-4995] - 修复在Kafka Streams剩余的findbugs警告
[KAFKA-5003] - StreamThread捕获InvalidTopicException
[KAFKA-5005] - JoinIntegrationTest偶发性故障
[KAFKA-5013] - 当findbugs故障时，构建失败
[KAFKA-5014] - SSL通道未就绪，但tcp已建立且服务器挂起，不会发送元数据
[KAFKA-5038] - 运行多个kafka流实例会导致一个或多个实例对文件争抢
[KAFKA-5040] - 将Streams生产者重试次数从默认值0增加
[KAFKA-5042] - InFlightRequests#isEmpty() 始终返回故障
[KAFKA-5043] - 添加FindCoordinatorRequest RPC存根并更新KIP-98的InitPidRequest
[KAFKA-5047] - 在KafkaStreams中使用GlobalKTable时NullPointerException
[KAFKA-5049] - 应该对每个ZkUtils实例进行Chroot检查
[KAFKA-5051] - 避免在安全关键的TLS代码路径中进行DNS反向查找
[KAFKA-5055] - 即使将FailOnInvalidTimestamp用作提取器，Kafka Streams跳过记录速率传感器也会产生非零值
[KAFKA-5073] - Kafka Streams在重新平衡侦听器中抛出异常后再次平衡
[KAFKA-5075] - 如果消费者的提取位置已经增加，则将异常延迟到下一个pollOnce()
[KAFKA-5078] - 如果迭代器已经移动到有效的记录上，PartitionRecords.fetchRecords（...）应将异常推迟到下一个调用
[KAFKA-5081] - 两个版本的jackson-annotations-xxx.jar分布在tgz
[KAFKA-5086] - 每次请求topic元数据时，更新元数据中的主题到期时间
[KAFKA-5088] - 代码注释中的一些拼写错误
[KAFKA-5090] - Kafka Streams SessionStore.findSessions javadoc broken
[KAFKA-5095] - ThreadCacheTest.cacheOverheadsSmallValues间歇性故障
[KAFKA-5099] - 来自KIP-101的副本删除复原
[KAFKA-5100] - ProducerPerformanceService由解析导致的故障
[KAFKA-5101] - 删除KafkaController的incrementControllerEpoch方法参数
[KAFKA-5119] - SocketServerTest.testMetricCollectionAfterShutdown中的短暂性故障
[KAFKA-5135] - 控制器健康指标（KIP-143）
[KAFKA-5140] - 片状复位集成测试
[KAFKA-5143] - Windows平台不提供kafka-broker-api-versions.bat
[KAFKA-5144] - MinTimestampTracker使用的混淆变量名
[KAFKA-5150] - LZ4解压比Snappy在小批量/消息上慢4-5倍
[KAFKA-5164] - SetSchemaMetadata不能正确地替换结构中的模式
[KAFKA-5167] - 由于LockException，流任务在重新平衡后被卡住
[KAFKA-5169] - KafkaConsumer.close应该是幂等的
[KAFKA-5170] - KafkaAdminClientIntegration测试应该等元数据传播给所有broker
[KAFKA-5172] - CachingSessionStore不能正确的fetchPrevious
[KAFKA-5173] - SASL测试失败，无法在JAAS配置中找到“KafkaServer”或“sasl_plaintext.KafkaServer”条目
[KAFKA-5174] - RocksDb可能会在仅有1个核心的环境中停顿
[KAFKA-5198] - RocksDbStore＃openIterators应该被同步，因为它是从多个线程访问的
[KAFKA-5203] - 百分位数计算不正确
[KAFKA-5205] - 缓存SessionStore不使用默认的keyStore。
[KAFKA-5206] - RocksDBSessionStore不使用默认的aggSerde。
[KAFKA-5211] - 抛出异常后，KafkaConsumer不应该跳过损坏的消息。
[KAFKA-5213] - 在ensureOpenForRecordAppend中出IllegalStateException
[KAFKA-5215] - AdminClient#describeTopics的小JavaDoc修复
[KAFKA-5216] - 缓存Session/Window仓库可能在iterator.peeNextKey()返回错误
[KAFKA-5226] - SourceNodeRecordDeserializer.deserialize中的NullPointerException（NPE）
[KAFKA-5229] - 反射在扫描类路径时日志有过多的警告
[KAFKA-5230] - Connect转换的推荐值包含错误的类名
[KAFKA-5232] - 如果在其名称中包含点的topic被标记为删除但在上一次正常运行期间尚未被删除，则kafka broker无法启动
[KAFKA-5236] - 使用0.8.2日志消息格式使用Snappy压缩时磁盘日志大小的回归
[KAFKA-5241] - 恢复状态后，GlobalKTable不检查offset
[KAFKA-5244] - 删除单例度量的测试中断了后面的指标测试
[KAFKA-5250] - handleFetchRequest应该在调节后进行下转换
[KAFKA-5263] - 当网络连接丢失时,kafka客户端使用手动分区分配占用100％的CPU
[KAFKA-5265] - 将ACL，Config，NodeVersions类移动到org.apache.kafka.common中
[KAFKA-5266] - 消费者偏移重置工具（KIP-122）的后续改进。
[KAFKA-5278] - kafka-console-consumer：`--value-deserializer`不工作，但`--property value.deserializer`工作
[KAFKA-5289] - 一个StopReplicaRequest将导致两个响应
[KAFKA-5293] - 如果用户覆盖了reconnect.backoff.ms，则不应用指数退避
[KAFKA-5294] - PlainSaslServerFactory应该允许在getMechanismNames中的空Map
[KAFKA-5303] - FetchRequest不实现toString
[KAFKA-5305] - 在ReplicaFetcher中缺少记录信息
[KAFKA-5309] - 一个线程死后，仓库无法查询
[KAFKA-5316] - 日志清理增加message的大小，并使缓冲区溢出导致cleaner的崩溃
[KAFKA-5321] - 如果输出缓冲区不够大，MemoryRecords.filterTo返回损坏的数据
[KAFKA-5324] - AdminClient：添加关闭和超时，修复一些超时错误
[KAFKA-5325] - Kafka Kerberos更新过程中的连接丢失
[KAFKA-5329] - broker元数据缓存中的副本列表可能与zookeeper的顺序不同
[KAFKA-5334] - rocksdb.config.setter必须是类实例，而不是类名
[KAFKA-5336] - ListGroup需要在Cluster上Describe，但是命令行AclCommand工具不允许设置此选项
[KAFKA-5338] - 在ResetIntegrationTest中有一个Misspell
[KAFKA-5344] - 将message.timestamp.difference.max.ms更改回Long.MaxValue
[KAFKA-5345] - 一些socket连接在Kafka Streams重新启动后未关闭
[KAFKA-5349] - KafkaConsumer偶尔会点击IllegalStateException
[KAFKA-5350] - 在Streams API中修改不稳定的注解
[KAFKA-5353] - baseTimestamp应该始终具有创建时间戳
[KAFKA-5354] - MirrorMaker不保存标题
[KAFKA-5360] - 下转换的未压缩批次应该尊寻提取偏移量
[KAFKA-5361] - 为Streams API添加EOS集成测试
[KAFKA-5362] - 为Streams API添加EOS系统测试
[KAFKA-5368] - Kafka Streams跳过记录比率传感器在时间戳有效时产生非零值
[KAFKA-5373] - ConsoleConsumer打印出对象地址，不是预期的。
[KAFKA-5374] - 当与旧的broker通讯时，AdminClient会获取“关于未知关联ID的服务器返回的信息”
[KAFKA-5375] - 交易：当有broker增加时，并发交易消费者会丢失消息
[KAFKA-5380] - 短暂的测试故障: KafkaConsumerTest.testChangingRegexSubscription
[KAFKA-5382] - 如果topic名称包含其中一个索引后缀，则日志恢复可能会失败
[KAFKA-5385] - 交易生产者允许批次到期并提交交易
[KAFKA-5394] - KafkaAdminClient#timeoutCallsInFlight无法正常运行
[KAFKA-5395] - 分布式Herder死锁关机
[KAFKA-5404] - ClientCompatibilityTest增加更多的AdminClient验证
[KAFKA-5413] - 由于段文件中的偏移量较大，日志清除失败
[KAFKA-5414] - 控制台消费者偏移提交回归
[KAFKA-5415] - TransactionCoordinator没有完成向PrepareCommit状态的转换
[KAFKA-5416] - TransactionCoordinator没有完成向CompleteCommit的转换
[KAFKA-5418] - 如果topic被标记为删除，则ZkUtils.getAllPartitions()可能会失败
[KAFKA-5422] - 多个生产请求失败导致TransactionManager中的无效状态转换
[KAFKA-5433] - 短暂测试故障：SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl
[KAFKA-5442] - Streams生产者`client.id`对于EOS来说并不是唯一的
[KAFKA-5448] - TimestampConverter的“type”配置与基本的Transformation“type”配置冲突
[KAFKA-5449] - 薄片测试TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData
[KAFKA-5450] - 启动脚本在系统测试中连接时间太短
[KAFKA-5455] - 为消费者和生产者更新java文档以便更新EOS
[KAFKA-5456] - 如果压缩V0或V1记录大于批量大小，生产者使用NPE失败
[KAFKA-5457] - MemoryRecordsBuilder.hasRoomfor在计算可用空间时不考虑标题
[KAFKA-5463] - 新增broker时，控制器不正确地记录机架信息
[KAFKA-5472] - 连接器验证REST端点返回“组”中的重复条目
[KAFKA-5475] - 连接器配置验证REST API末端不包括用于转换的字段
[KAFKA-5477] - TransactionalProducer休眠在背对背交易中休眠是不需要的
[KAFKA-5486] - org.apache.kafka日志记录应该去server.log
[KAFKA-5491] - ProducerPerformance工具应该支持交易
[KAFKA-5498] - 连接验证API会在正确的请求顺序之后停止返回某些字段的建议

任务

[KAFKA-3763] - 在0.11.0.0中移除弃用的API 
[KAFKA-4422] - 降低对Scala 2.10的支持 (KIP-119)
[KAFKA-4679] - 从Connect API中删除不稳定的标记
[KAFKA-5045] - KTable实现和改进语义

测试

[KAFKA-4574] - ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade中的瞬时故障，具有security_protocol = SASL_PLAINTEXT，SSL
[KAFKA-4703] - 用两个具有不同JAAS上下文的SASL_SSL监听器进行测试
[KAFKA-5126] - 在MockProducer中实现KIP-98事务方法
[KAFKA-5366] - 在系统测试中添加并发事务读取和写入的情况
[KAFKA-5371] - SyncProducerTest.testReachableServer已经变得很轻薄

Sub-task

[KAFKA-2273] - KIP-54: 添加重新平衡，重新分配到服务器定义的策略列表
[KAFKA-2363] - ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread暂时性故障
[KAFKA-3155] - 在kafka.api.PlaintextProducerSendTest.testFlush中暂时性的故障
[KAFKA-3264] - 将旧的Scala消费者和相关类标记为不推荐使用
[KAFKA-3265] - 创建Java管理客户端
[KAFKA-3266] - 实现用于创建，更改和列出ACL的KIP-140 RPC和API
[KAFKA-3267] - 描述/改变配置协议，服务器和客户端（KIP-133）
[KAFKA-3875] - 短暂性的测试故障: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime
[KAFKA-3896] - 不稳定的测试KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations
[KAFKA-4198] - 短暂性的测试故障: ConsumerBounceTest.testConsumptionWithBrokerFailures
[KAFKA-4222] - 在QueryableStateIntegrationTest.queryOnRebalance中的短暂性测试故障
[KAFKA-4378] - 地址2.12 eta扩展警告
[KAFKA-4421] - 更新发布过程，以便Scala 2.12被发布
[KAFKA-4467] - 使用docker在travis-ci上运行测试
[KAFKA-4569] - 暂时性故障org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable
[KAFKA-4588] - QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable在jenkins中偶发性故障
[KAFKA-4642] - 提高ProcessorStateManager的测试覆盖率
[KAFKA-4644] - 提高StreamsPartitionAssignor的测试覆盖率
[KAFKA-4645] - 提高ProcessorTopology的测试覆盖率
[KAFKA-4646] - 提高AbstractProcessorContext的测试覆盖率
[KAFKA-4647] - 提高GlobalStreamThread测试覆盖率
[KAFKA-4648] - 提高StreamTask的测试覆盖率
[KAFKA-4649] - 提高GlobalStateManagerImpl的测试覆盖率
[KAFKA-4652] - 提高KStreamBuilder的测试覆盖率
[KAFKA-4654] - 提高MemoryLRUCache的测试覆盖率
[KAFKA-4657] - 提高CompositeReadOnlyWindowStore的测试覆盖率
[KAFKA-4660] - 提高KafkaStreams的测试覆盖率
[KAFKA-4662] - 提高TopologyBuilder的测试覆盖率
[KAFKA-4786] - 短暂性测试故障: ConsumerCoordinatorTest.testHeartbeatThreadClose
[KAFKA-4816] - 对幂等/交易型的producer消息格式的变更
[KAFKA-4817] - producer实现幂等性
[KAFKA-4818] - 实现交易型客户端
[KAFKA-4859] - 短暂测试故障: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion (again)
[KAFKA-4935] - 考虑禁用消息格式V2的记录级CRC校验
[KAFKA-4948] - 在kafka.admin.DescribeConsumerGroupTest.testDescribeExistingGroupWithNoMembersWithNewConsumer的故障
[KAFKA-4954] - 请求处理程序线程利用率配额的实现和单元测试
[KAFKA-4955] - 添加网络处理程序线程利用率以请求配额计算
[KAFKA-4957] - 添加请求配额的文档
[KAFKA-4973] - AdminClientTest.testDeleteRecordsWithException短暂性故障
[KAFKA-4986] - 每个任务支持添加生产者
[KAFKA-4990] - 为事务添加请求/响应类（KIP-98）
[KAFKA-5006] - KeyValueStore.put可能抛出与当前投入尝试无关的异常
[KAFKA-5019] - “正好一次”的升级说明
[KAFKA-5021] - 更新消息传递语义部分以考虑KIP-98
[KAFKA-5028] - 将kafka控制器转换为单线程事件队列模型
[KAFKA-5031] - validateMessagesAndAssignOffset中的其他验证
[KAFKA-5033] - 重新考虑幂等生产者的默认重试
[KAFKA-5069] - 添加控制器集成测试
[KAFKA-5093] - 在重建生产者ID映射时仅加载批处理标题
[KAFKA-5103] - Refactor AdminUtils使用zkUtils方法而不是zkUtils.zkClient
[KAFKA-5107] - 从ControllerContext中删除首选副本选举状态
[KAFKA-5121] - 实现KIP-98的交易指数
[KAFKA-5124] - shouldInnerLeftJoin单元测试故障
[KAFKA-5128] - TransactionCoordinator - 检查中间broker协议和消息格式，如果不兼容，则引发错误
[KAFKA-5129] - TransactionCoordinator - 为每个请求增加ACL验证
[KAFKA-5130] - 将InterBrokerSendThread更改为每个broker使用一个队列
[KAFKA-5131] - WriteTxnMarkers并在分区移植中完成commit / abort
[KAFKA-5132] - 中止长时间运行的交易
[KAFKA-5136] - 将CoordinatorEpoch从WriteTxnMarkerRequest移动到TxnMarkerEntry
[KAFKA-5147] - KafkaProducer的TransactionManager需要对同步进行审查
[KAFKA-5151] - 重构事务处理器内存结构和错误处理逻辑
[KAFKA-5160] - KIP-98 : broker处理TxnOffsetCommitRequest
[KAFKA-5162] - 将AdminClient的引用添加到docs/api.html
[KAFKA-5171] - TC不应该接受空字符串事务ID
[KAFKA-5175] - 短暂性故障: ControllerIntegrationTest.testPreferredReplicaLeaderElection
[KAFKA-5179] - 验证过程中日志连接终止
[KAFKA-5180] - 短暂性故障: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch
[KAFKA-5182] - 短暂性故障: RequestQuotaTest.testResponseThrottleTime
[KAFKA-5186] - 在升级时避免生产者状态的初始化的开销
[KAFKA-5188] - 添加事物生产者的集成测试
[KAFKA-5191] - 自动生成消费者提取器指标
[KAFKA-5196] - LogCleaner应该是事务感知的
[KAFKA-5202] - 对于持续有交易的topic删除
[KAFKA-5227] - SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe
[KAFKA-5231] - TransactinoCoordinator在中断公开交易时不会触发epoch
[KAFKA-5247] - 消费者GroupCoordinator应继续实现偏移顺序的承诺offset，即使是交易offset提交
[KAFKA-5248] - 从TxnOffsetCommit RPC中删除保留时间
[KAFKA-5249] - 事务索引恢复不正确快照
[KAFKA-5251] - 当事务中止时，生产者应该丢弃排队发送
[KAFKA-5252] - 修复片断测试LogCleanerTest.testCommitMarkerRemoval
[KAFKA-5258] - 将所有分区和副本状态转换规则移动到其状态
[KAFKA-5259] - TransactionalId授权应该意味着ProducerId授权
[KAFKA-5260] - 除非事务已经开始，生产者不应发送AbortTxn
[KAFKA-5268] - TransactionsBounceTest偶尔会看到INVALID_TXN_STATE错误
[KAFKA-5269] - TransactionBounceTest由于分区错误偶尔会失败
[KAFKA-5273] - KafkaConsumer.committed()应该从服务器获取最新的承诺offset
[KAFKA-5274] - 查看并改进第一个版本的AdminClient Javadoc（KIP-117）
[KAFKA-5275] - 审查并潜在地调整初始版本的AdminClient API（KIP-117）
[KAFKA-5279] - TransactionCoordinator必须到期处理事务
[KAFKA-5280] - 保护并发访问缓存的事务状态
[KAFKA-5281] - KIP-98 /交易的系统测试
[KAFKA-5282] - 交易整合测试：使用工厂方法跟踪开放的生产者和消费者，并将其全部关闭在tearDown上
[KAFKA-5283] - 更新客户端和服务器代码，以确保epoch和序列号环绕
[KAFKA-5291] - AdminClient不应触发自动创建topic
[KAFKA-5292] - 修复AdminClient中的授权检查
[KAFKA-5308] - TC应该在WriteTxnMarker响应中处理UNSUPPORTED_FOR_MESSAGE_FORMAT
[KAFKA-5310] - 在重新注册期间复位ControllerContext
[KAFKA-5317] - 更新KIP-98以反映实施过程中的变化。
[KAFKA-5320] - 更新产生/获取阈值时间指标，以获得阈值
[KAFKA-5322] - 解决AddPartition响应错误代码不一致
[KAFKA-5339] - 具有硬borker重启的交易系统测试偶尔失败
[KAFKA-5340] - 为批量拆分添加其他测试用例，以确保幂等/事务元数据被保留
[KAFKA-5351] - broker干净重启测试将broker永久性置于“CONCURRENT_TRANSACTIONS”状态
[KAFKA-5355] - broker在read_committed模式下将消息超出“最新稳定offset”返回到事务性消费者
[KAFKA-5357] - 事务协调器中的StackOverFlow错误
[KAFKA-5364] - 生产者尝试在将事务添加到事务之前发送事务消息
[KAFKA-5365] - 修复影响magic v0和v1的压缩邮件迭代中的回归
[KAFKA-5376] - 事务：并发事务消费者读取中止的消息
[KAFKA-5378] - Fetch请求中未返回最后稳定的offset
[KAFKA-5427] - 尝试在错误后中止事务时，事务性生产者找不到协调者
[KAFKA-5428] - 事务性生产者在中止错误状态下不正确地中止批处理
[KAFKA-5429] - 生产者IllegalStateException：批处理已经完成
[KAFKA-5435] - 如果没有保存快照，则生成状态丢失
[KAFKA-5437] - TransactionalMessageCopier应该在测试关机时被强行杀死
[KAFKA-5438] - WriteTxnMarkers处理程序中的UnsupportedOperationException异常
[KAFKA-5443] - 消费者应该使用批次的最后一个偏移设置下一个抓取偏移
[KAFKA-5502] - 根据处理broker变更，从zookeeper读取当前的broker