时间戳

首页 > 解决方案 > 卡夫卡客户端兼容性

apache-kafka - 卡夫卡客户端兼容性

问题描述

我们在我们的 Linux red-hat 服务器上使用以下 Kafka 客户端

0.8.1 Release
Released March 12, 2014
Release Notes
Source download: kafka-0.8.1-src.tgz (asc, md5)
Binary downloads:
Scala 2.8.0 - kafka_2.8.0-0.8.1.tgz (asc, md5)
Scala 2.8.2 - kafka_2.8.2-0.8.1.tgz (asc, md5)
Scala 2.9.1 - kafka_2.9.1-0.8.1.tgz (asc, md5)
Scala 2.9.2 - kafka_2.9.2-0.8.1.tgz (asc, md5)
Scala 2.10 - kafka_2.10-0.8.1.tgz (asc, md5)
We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.9.2 is recommended).

从 Kafka 代理端，我们将 Kafka 代理版本升级到 1.X 版本

现在我们需要知道 Kafka 客户端兼容性（0.8.1）是否适合 Kafka 代理 - 1.0

搜索后我们发现这篇文章确定 Kafka-Client 与 kafka-broker 的兼容性

但我们没有发现 Kafka 客户端 0.8.1 与 Kafka 代理版本的兼容性

如何知道适合 Kafka 客户端版本 - 0.8.1 的 Kafka 代理版本是什么？

标签： apache-kafkakafka-consumer-apikafka-producer-api

解决方案

运行 0.8.1 的 Kafka 客户端不兼容 1.0 代理，甚至 0.9 代理，因为 KIP-35 在客户端 API 请求中包含协议版本以处理更好的跨版本支持

你可以在这里参考维基 - https://cwiki.apache.org/confluence/display/KAFKA/Compatibility+Matrix

我建议也去 2.x 版本

推荐阅读