Определить совместимость Kafka-Client с kafka-брокером

Question

В удаленном облачном кластере kafka брокеры kafka будут обновлены до новой версии (5.1), и поэтому применяется новый протокол kafka.

Теперь я должен обновить свой клиент kafka, чтобы он мог подключаться.Прямо сейчас я использую следующие относящиеся к kafka зависимости в своем приложении для весенней загрузки:

<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-клиентов и kafka-брокеров.

• У кого-нибудь есть идеи, как успешно выполнить обновление?
• У кого-нибудь есть матрица совместимости для этих зависимостей?

Answer 1

На странице проекта Spring для Apache Kafka имеется ссылка на сливную матрицу (вместе с совместимостью spring-kafka / kafka-clients).

0.9очень, очень старый.

Как правило, клиенты / брокеры новее, чем 0.10.2.0, могут общаться друг с другом, но если записи имеют заголовки, вам понадобится клиент> = 0.11.0.0.