确定 Kafka-Client 与 kafka-broker 的兼容性 [英] Determine the Kafka-Client compatibility with kafka-broker

问题描述

在远程 kafka 云集群中，kafka 代理将更新到新版本 (5.1)，因此适用新的 kafka 协议.

Within the remote kafka cloud cluster, the kafka brokers will be updated to a new version (5.1) and therefore a new kafka protocol applies.

现在我应该更新我的 kafka 客户端以能够连接.现在我在 spring-boot 应用程序中使用以下 kafka 相关依赖项:

Now I should update my kafka client to being able to connect. Right now I am using following kafka relevant dependencies in my spring-boot application:

<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-parent</artifactId>
<version>1.3.8.RELEASE</version>

<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-kafka</artifactId>
<version>2.0.1.RELEASE</version>

<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<version>1.0.3.RELEASE</version>

<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>1.0.3.RELEASE</version>

<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.9.0.1</version>

<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.9.0.1</version>

我已经为 kafka-clients 和 kafka-brokers 搜索了合适的兼容性矩阵.

I already searched for an appropriate compatibility matrix for kafka-clients and kafka-brokers.

• 有人知道如何成功升级吗?
• 有没有人有这个依赖项的兼容性矩阵?

推荐答案

有一个链接到 Spring for Apache Kafka 项目页面上的 noreferrer">融合矩阵(连同 spring-kafka/kafka-clients 兼容性).

There's a link to the confluent matrix on the Spring for Apache Kafka project page (along with spring-kafka/kafka-clients compatibility).

0.9 已经非常非常旧了.

0.9 is very, very old.

通常，比 0.10.2.0 更新的客户端/代理可以相互通信，但如果记录有标头，您将需要一个 >= 0.11.0.0 的客户端.

Typically, clients/brokers newer than 0.10.2.0 can talk to each other, but if records have headers, you will need a client >= 0.11.0.0.

这篇关于确定 Kafka-Client 与 kafka-broker 的兼容性的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！