Spring Cloud Stream 嵌入式kafka

Question

春季队，

我用

3.0.5

版本的 spring cloud stream 进行了一个非常简单的测试。它曾经工作过。

@EmbeddedKafka
@SpringBootTest
public class KafkaTest {

    @Autowired
    private EmbeddedKafkaBroker broker;

    @Test
    public void test(){
        System.out.println(broker.getBrokersAsString());
    }

}

但是现在我有这个错误。

java.lang.ExceptionInInitializerError
Caused by: java.lang.IllegalStateException: Failed to obtain TestUtils.createBrokerConfig method; client version: 3.3.2
Caused by: java.lang.IllegalStateException: Failed to introspect Class [kafka.utils.TestUtils] from ClassLoader [jdk.internal.loader.ClassLoaders$AppClassLoader@531d72ca]
Caused by: java.lang.NoClassDefFoundError: org/apache/zookeeper/data/ACL
Caused by: java.lang.ClassNotFoundException: org.apache.zookeeper.data.ACL

出于某种原因，Spring 似乎正在使用旧版本的 zookeeper 依赖项 (3.6.3)，它没有

org.apache.zookeeper.data.ACL

.

我有一个简单的可复制项目这里.