spring kafka单元测试出错：无法确定testutils.createbrokerconfig()

yruzcnhs 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(388)

我使用的是springkafka和springkafka test2.1.5.release，我运行的是springkafka文档中的单元测试示例，特别是这个：代码
在这条线上：

@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

1条答案

要将kafka客户端1.1.x与spring一起用于ApacheKafka 2.1.x，请参见附录a。重写依赖项以使用1.1.x kafka客户端。