此博客条目https://www.confluent.io/blog/stream-processing-part-2-testing-your-streaming-application/ 引用类embeddedkafkacluster，该类应位于库kafka streams test utils中。
但是，库中缺少此类，例如org.apache.kafka/kafka streams test utils/2.5.1。
我想我可以使用github的源代码https://github.com/a0x8o/kafka/blob/master/streams/src/test/java/org/apache/kafka/streams/integration/utils/embeddedkafkacluster.java
但是这个源代码引用了一些类，例如kafka.zk.embeddedzookeeper和kafka.utils.mocktime，我假设这些类必须在org.apache.kafka/kafka\u 2.13/2.5.1这样的库中。不幸的是，他们也失踪了。
在这种情况下，将项目配置为使用embeddedkafkacluster的最佳方法是什么？
谢谢
鲍里斯