在远程 kafka 云集群中,kafka 代理将更新到新版本 (5.1),因此适用新的 kafka 协议。
现在我应该更新我的 kafka 客户端以能够连接。现在我在 spring-boot 应用程序中使用以下 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>
Run Code Online (Sandbox Code Playgroud)
我已经为 kafka-clients 和 kafka-brokers 搜索了合适的兼容性矩阵。