Kafka 客户端兼容性

Question

我们在 Linux 红帽服务器上使用以下 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

经过搜索我们找到了这个 post

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

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

Answer 1

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

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

我建议也去 2.x 发布

Kafka 客户端兼容性

Kafka Client compatibility

apache-kafka

kafka-consumer-api

kafka-producer-api