ошибка kafka: версии MetadataRequest старше 4 не поддерживают поле allowAutoTopicCreation

Question

Я разработал приложение для весенней загрузки, используя boot-версию 2.1.3.RELEASE. Добавлены зависимости kafka-client, spring-fafka, kafka_2.12 и kafka-streams без конкретной версии. Приложение предназначено для открытия потока из темы кафки и выполнения агрегирования по группам по ключам во временном окне. В режиме отладки регистрируется следующая ошибка.

org.apache.kafka.common.errors.UnsupportedVersionException: версии MetadataRequest старше 4 не поддерживают поле allowAutoTopicCreation

2019-10-18 09: 18: 05.050 DEBUG 6435 --- [0c5acc95c-admin] oakclients.admin.KafkaAdminClient: [AdminClient clientId = CAG__CNTS_service_ads_2-d1d85a17-42e5-4d98-9ef8-ed90c5acc95d-call= 1571370604855) не удалось создать исключение без возможности повторения после 1 попытки.

java.lang.Exception: UnsupportedVersionException: версии MetadataRequest старше 4 не поддерживают поле allowAutoTopicCreation в org.apache.kafka.clients. admin.KafkaAdminClient $ Call.fail (KafkaAdminClient.java:612) ~ [kafka-clients-2.0.1.jar: na] at> org.apache.kafka.clients.admin.KafkaAdminClient $ AdminClientRunnable.handleResponses (KafkaAdminli:984) [kafka-clients-2.0.1.jar: na] at> org.apache.kafka.clients.admin.KafkaAdminClient $ AdminClientRunnable.run (KafkaAdminClient.java:1124) [kafka-clients-2.0.1.jar: na] в java.lang.Thread.run (Thread.java:748) [na: 1.8.0_172]

Answer 1

Boot 2.1.x (текущая версия 2.1.9) использует spring-kafka 2.2.x и по умолчанию использует клиенты 2.0.1 kafka. См. Страницу проекта для матрицы совместимости . Хотя вы обычно можете использовать более новые клиенты со старыми брокерами (начиная с 0.10), конечно, вы можете использовать только те функции, которые поддерживает брокер.

0.10.xx просто слишком стар для новых версий spring-kafka.