Ошибка с модульным тестированием Spring Kafka: не удалось определить TestUtils.createBrokerConfig ()

Question

Я использую spring-kafka и spring-kafka-test 2.1.5.RELEASE, и я запускаю пример модульного теста в документации по spring-kafka, а именно: Code

На этой строке:

@ClassRule
public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, TEMPLATE_TOPIC);

Я получаю эту ошибку:

java.lang.ExceptionInInitializerError ... Caused by: java.lang.RuntimeException: Failed to determine TestUtils.createBrokerConfig() method

Я в недоумении, почему пример теста на официальной документации не работает, и я не могу найти какую-либо ссылку на эту ошибку в Интернете. Буду благодарен, если кто-нибудь поймет, что может быть не так.

Это мой pom.xml, на случай, если мне не хватает моих зависимостей: https://pastebin.com/nT8j5LQ5

Answer 1

Чтобы использовать kafka-clients 1.1.x с Spring для Apache Kafka 2.1.x, см. Приложение A. Переопределение зависимостей для использования 1.1.x kafka-клиентов .