2019年2月15号，发布Kafka 2.1.1。
以下是2.1.1版本中解决JIRA问题的摘要，有关该版本的完整文档，入门指南以及关于该项目的信息，请参考Kafka官方文档，或kafka中文教程。
有关升级的注意事项：在升级你的集群之前，请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更，性能变化以及可能影响Kakfa生产的任何其他变化。
改进
[KAFKA-6928] - InternalTopicManager中StreamsPartitionAssignor重试2次。
[KAFKA-7389] - 升级spotBugs以支持Java 11
[KAFKA-7584] - 如果将max.in.flight.request.per.connect指定为String，StreamsConfig将抛出ClassCastException
[KAFKA-7610] - 在JoinGroup初始化中检测消费者故障
[KAFKA-7671] - KStream/GlobalKTable连接不应重置重新分区标志
[KAFKA-7734] - Metrics标签应使用LinkedHashMap来保证顺序
[KAFKA-7837] - maybeShrinkIsr可能不会立即反映出OfflinePartitions
Bug
[KAFKA-7897] - 使用旧消息格式版本的epoch缓存无效
[KAFKA-3832] - Kafka Connect的JSON Converter从不输出空值
[KAFKA-5117] - Kafka Connect REST端点显示密码类型值
[KAFKA-6388] - 尝试滚动已存在的segment时出错
[KAFKA-6833] - KafkaProducer抛出"Invalid partition given with record"异常
[KAFKA-7253] - 创建连接器时，worker响应的连接器类型始终为null
[KAFKA-7443] - 当本地检查点的起始偏移量小于changelog主题的起始偏移量时，从changelog主题恢复状态存储时的OffsetOutOfRangeException
[KAFKA-7518] - FutureRecordMetadata.get从超时计算的截止时间不使用timeunit
[KAFKA-7532] - 在错误消息中从关闭代理列表中“Removed ArrayBuffer()（kafka.controller.KafkaController）”丢失字符串化。
[KAFKA-7536] - TopologyTestDriver无法预先填充KTable或GlobalKTable
[KAFKA-7549] - 使用zstd压缩的旧ProduceRequest不会向客户端返回错误
[KAFKA-7576] - 复制拉取程序线程的动态更新可能无法启动/关闭拉取程序
[KAFKA-7607] - 在关闭期间，NetworkClientUtils.sendAndReceive可能需要很长时间才能返回
[KAFKA-7620] - 当TTL不为空时，ConfigProvider在KafkaConnect中被破坏
[KAFKA-7655] - 在某些情况下，来自`Kafka Streams`的元数据垃圾邮件请求，潜在的DOS
[KAFKA-7660] - Stream Metrics - Memory Analysis
[KAFKA-7678] - 由于java.lang.NullPointerException，无法关闭生产者
[KAFKA-7692] - 由于ProducerStateManager.append中的sequenceId溢出导致的updateFirstUnstableOffset NPE
[KAFKA-7693] - "IllegalArgumentException：在Kafka Client中使用的无效的负序号
[KAFKA-7697] - kafka.cluster.Partition中可能出现死锁
[KAFKA-7702] - 带前缀的ACL不适用于单字符前缀
[KAFKA-7704] - kafka.server.ReplicaFetechManager.MaxLag.Replica指标报告错误
[KAFKA-7705] - 更新javadoc以获取delivery.timeout.ms或linger.ms的值
[KAFKA-7709] - 在Sender.getExpiredInflightBatches中迭代多个分区时发生ConcurrentModificationException
[KAFKA-7741] - 通过SBT的不良依赖
[KAFKA-7755] - Kubernetes - Kafka客户端只解析一次DNS条目
[KAFKA-7759] - 在Connect REST API中禁用WADL输出
[KAFKA-7768] - Java doc链接404
[KAFKA-7786] - leader时期的快速更新可能会停止分区提取 FENCED_LEADER_EPOCH
[KAFKA-7840] - cleanup.policy的文档已过期
[KAFKA-7873] - KafkaBasedLog的消费者应该始终在开始时寻求开始
[KAFKA-7890] - 如果broker的主机名发生更改，则会使broker的ClusterConnectionState缓存无效。
[KAFKA-7902] - SASL/OAUTHBEARER可能无法连接：javax.security.sasl.SaslException：无法在Subject的私有证书(size=2)中找到OAuth Bearer令牌。
任务
[KAFKA-7503] - Connect的集成测试框架
子任务
[KAFKA-5503] - 幂等producer在获取ProducerId时忽略关闭
