如何重置kafka以将其集成到JUnit测试过程中？

Question

我正在测试和调试一个运行在kafka顶部并使用Samza的事件源（或有状态流处理）应用程序。我想删除kafka中的队列和主题，以便samza作业在启动时获得空的kafka安装。

我该怎么做？？

我正在使用gradle环境+eclipse和JUnit。我从eclipse运行集成测试（作为JUnit测试）。

如何实现装载自动化？我是否应该创建一个特定的测试类来设置环境并启动kafka和Zookeeper？有没有参考的例子/代码？我们的想法是加载环境，运行一些测试，然后停止。如果这个过程能在几秒钟内完成，那就更好了。

Answer 1

清除单个主题有不同的方法。所有这些都可以扩展到清除你所有的话题。然而，我认为您问的是一个与为Kafka创建一个基线环境有关的更大的问题--这也许是您在测试时所需要的。或者你有一个每次都从头开始的生产过程。这些其实是不同的场景。

用于测试

如果你说的是测试，那么我会故意用蛮力。首先，我将把Kafka配置成我希望它在启动时的样子。然后我将关闭它并备份它--或者使用tar或者甚至制作一个磁盘映像（如果我使用的是VM的话）。

然后，不是每次“重置”Kafaka，而是创建所有主题的新版本，并更新字典以将虚拟主题名称映射到新创建的主题版本。