2019年6月1号，发布Kafka 2.2.1。
以下是2.2.1版本中解决JIRA问题的摘要，有关该版本的完整文档，入门指南以及关于该项目的信息，请参考Kafka官方文档，或kafka中文教程。
有关升级的注意事项：在升级你的集群之前，请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更，性能变化以及可能影响Kakfa生产的任何其他变化。
改善
[KAFKA-6789] - 在AdminClient请求中添加重试逻辑
[KAFKA-8014] - 扩展Connect集成测试以动态添加和删除工作程序
[KAFKA-8126] - 片Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask
[KAFKA-8348] - 优化kafkaStreams文档
Bug
[KAFKA-5141] - WorkerTest.testCleanupTasksOnStop由于NPE导致的瞬时故障
[KAFKA-7601] - 在消息格式版本升级期间处理消息格式降级
[KAFKA-7633] - Kafka Connect需要获得创建内部topic的权限，即使存在
[KAFKA-7855] - Kafka Streams Maven Archetype快速入门无法开箱即用
[KAFKA-7866] - 事务索引追加失败后重复的offset
[KAFKA-7895] - Ktable supress运算符为每个窗口的相同key发出多个记录
[KAFKA-7939] - 片测试KafkaAdminClientTest#testCreateTopicsRetryBackoff
[KAFKA-7946] - 片测试DeleteConsumerGroupsTest#testDeleteNonEmptyGroup
[KAFKA-7974] - 初始化DNS查找失败时，KafkaAdminClient丢失工作线程/进入僵尸状态
[KAFKA-7976] - 片测试 DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
[KAFKA-7989] - 片测试 RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated
[KAFKA-8058] - ConnectRestExtensionContext不会从其ConnectClusterState返回连接器列表
[KAFKA-8062] - 当StreamThread死亡时，不会通知StateListener
[KAFKA-8063] - 片测试WorkerTest#testConverterOverrides
[KAFKA-8066] - 由于未能注册度量标准，ReplicaFetcherThread无法启动。
[KAFKA-8091] - 片测试DynamicBrokerReconfigurationTest#testAddRemoveSaslListener
[KAFKA-8098] - 片测试AdminClientIntegrationTest#testConsumerGroups
[KAFKA-8114] - 片测试DelegationTokenEndToEndAuthorizationTest#testNoGroupAcl
[KAFKA-8121] - ZooKeeperClient会话到期线程可能会在关闭后遗留下客户端
[KAFKA-8134] - ProducerConfig.LINGER_MS_CONFIG在kafka-clients 2.1文档中没有记录重大变更
[KAFKA-8142] - 如果消息在head中包含空值，则Kafka Streams与NPE将失败。
[KAFKA-8150] - 修复处理生成的RPC代码中的空数组时的错误
[KAFKA-8157] - 当设置“segment index bytes”时缺少“key.serializer”异常
[KAFKA-8190] - 密钥存储没有文件更改的话，不会更新sslcontext
[KAFKA-8204] - 流可能以错误的顺序刷新状态存储
[KAFKA-8227] - 缺少流和表的二元性链接部分
[KAFKA-8232] - 片测试kafka.admin.TopicCommandWithAdminClientTest.testTopicDeletion
[KAFKA-8240] - Source.equals()可能会因NPE而失败
[KAFKA-8241] - 密钥库动态更新失败，没有truststore的监听
[KAFKA-8248] - 生产者可能会失败IllegalStateException
[KAFKA-8254] - 抑制错误地将空topic传递给serdes
[KAFKA-8277] - 修复在ConnectHeaders中的NPE
[KAFKA-8289] - KTable, Long> 无法抑制
[KAFKA-8298] - ConcurrentModificationException优化重新分区节点时可能
[KAFKA-8304] - 注册REST扩展时，连接易受死锁影响
[KAFKA-8306] - 确保检查点日志起始offset和当前日志结束offset的一致性
[KAFKA-8323] - BloomFilter Rocks对象的内存泄漏
[KAFKA-8335] - 日志清理程序会跳过事务性标记和批记录，从而导致__consumer_offsets无限增长
[KAFKA-8352] - 连接系统测试404问题
Test
[KAFKA-8118] - 确保测试关闭ZooKeeper客户端，因为它们可能会影响后续测试
