Kafka 代理 1.10，客户端使用 API 0.10.2

【问题标题】：Kafka broker 1.10, clients using API 0.10.2Kafka 代理 1.10，客户端使用 API 0.10.2
【发布时间】：2019-02-23 18:53:55
【问题描述】：

我们是否应该更新我们的 Scala Kafka 客户端库依赖项（当前为 0.10.2）以匹配代理的 Kafka 版本（v1.1.0）？

从 0.10.2 版开始，Java 客户端（生产者和消费者）已经获得了与老经纪人沟通的能力。版本 0.10.2 客户端可以与 0.10.0 或更高版本的代理通信

客户端API版本落后于服务器版本有什么不良影响吗？更重要的是，我们能否安全地将 Kafka 客户端 API 库从 0.10.2 更新到 1.10？

【问题讨论】：

【解决方案1】：

虽然代理现在与旧客户端兼容，但使用旧客户端存在一些缺点。

主要是消息转换。在 1.1 和 0.10.2 之间，记录格式发生了变化。因此，默认情况下，旧客户端将强制代理在生产和消费时转换消息。转换非常消耗内存并且具有性能成本。见http://kafka.apache.org/documentation/#upgrade_11_message_format

那么显然老客户无法使用新功能。在 0.10.2 和 1.1 之间，有很多不错的功能，例如 Exactly Once semantics、better authentication feedback on failure、管理操作等

【讨论】：