Я использую локальный сервер версии 1.3 для SCDF, и у меня запущена версия 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), только что клонированной из мерзавца.
Простой поток времени | журнала развертывается нормально и подключается к клиенту kafka нормально, но затем начинает показывать:
Вызывается: java.lang.IllegalArgumentException: Magic v1 не поддерживает заголовки записи
Итак, я думаю, какая версия Kafka поддерживается? И рекомендуется ?, и мне следует использовать снимок приложения версии 2.0 с сервером версии 1.3?
спасибо!