Последняя (версия: Fishtown.SR2) spring-cloud-stream не поддерживает клиента kafka версии 2.1.0 или выше?

Question

Я использую последний Greenwich.SR1, который включает Spring-Cloud-Stream (версия: Fishtown.SR2) и локально запускаемая версия клиента kafka: 2.2.0 с использованием kafka_2.12-2.2.0.jar

Я хочу использовать последнюю версию клиента kafka 2.1 или выше с spring-cloud-stream, потому что он содержит некоторые важные исправления ошибок. Но когда я запускаю свое весеннее приложение, в его журналах написано

INFO 37812 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 2.0.1

Как я могу использовать spring-cloud-stream с последним клиентом kafka? Я хочу использовать max.task.idle.ms из последней StreamsConfig клиента kafka, но, похоже, последняя связка потоков Kafka Spring-Cloud-Stream не поддерживает Кафка клиент 2.1.0 или новее?

Answer 1

Правила создания версий Spring не позволяют нам переходить на новую версию клиентов kafka в точечной версии.Поскольку Fishtown использует Spring для Apache Kafka 2.2, он использует kafka-клиентов 2.0.x.

В следующей версии Spring для Apache Kafka будут использоваться клиенты 2.2.0 (или 2.3.0, если она будет доступна к тому времени).), поэтому следующая версия связывателя будет основана на более новых клиентах.

Связыватель канала сообщений работает, когда kafka-клиенты переопределены, но, к сожалению, связыватель потоков отсутствует из-за некоторых внутренних изменений API.