SCDF 1.3 版本支持的 Kafka 版本
Kafka version supported for versions for SCDF 1.3
我正在为 SCDF 使用本地服务器版本 1.3，并且有 kafka 版本 kafka_2.11-0.10.1.0 运行。我目前用来测试流程的应用程序是本地构建的 time-source-kafka (maven://org.springframework.cloud.stream.app:time-source-kafka:2.0.0.BUILD-SNAPSHOT) 刚刚从 git.
简单时间|日志流部署正常，连接到 kafka 客户端正常，但随后开始显示：
原因：java.lang.IllegalArgumentException：Magic v1 不支持记录头
那么，我猜想支持和推荐什么版本的 Kafka？我应该将应用程序的 2.0 版快照与服务器的 1.3 版一起使用吗？
谢谢！
SCDF 的版本并不那么重要，但 2.0 应用程序旨在与 Kafka 0.11 或更高版本一起使用。
将 1.3.x 应用与较旧的 Kafka 代理一起使用。
我正在为 SCDF 使用本地服务器版本 1.3，并且有 kafka 版本 kafka_2.11-0.10.1.0 运行。我目前用来测试流程的应用程序是本地构建的 time-source-kafka (maven://org.springframework.cloud.stream.app:time-source-kafka:2.0.0.BUILD-SNAPSHOT) 刚刚从 git.
简单时间|日志流部署正常，连接到 kafka 客户端正常，但随后开始显示： 原因：java.lang.IllegalArgumentException：Magic v1 不支持记录头
那么，我猜想支持和推荐什么版本的 Kafka？我应该将应用程序的 2.0 版快照与服务器的 1.3 版一起使用吗？
谢谢！
SCDF 的版本并不那么重要，但 2.0 应用程序旨在与 Kafka 0.11 或更高版本一起使用。
将 1.3.x 应用与较旧的 Kafka 代理一起使用。