如何自动化Kafka测试

Question

我们开发了一个小型系统,使用kafka对数据进行排队,然后使用该数据为用户下订单.我们手动测试了某些东西,但现在我们的目标是使过程自动化.是否有任何客户端可以测试它.虽然谷歌搜索的东西我找到了使用kafka客户端本身进行单元测试的方法,但我的目标是测试整个系统.请指南

编辑:我们的目的只是API测试,即只是后端而不是UI

Answer 1

您可以在集成测试中以编程方式启动Kafka,Kafka使用Zookeeper,因此首先查看Zookeeper TestingServer - 此类的实例使用给定端口创建并启动Zk服务器.

接下来看一下KafkaServerStartable.scala,你必须提供指向你的内存Zk服务器和调用startup()方法的配置,这里有一些代码:

import kafka.server.KafkaConfig; 
import kafka.server.KafkaServerStartable;
import java.util.Properties;

public KafkaTest() {
    Properties properties = createProperties();
    KafkaConfig kafkaConfig = new KafkaConfig(properties);
    KafkaServerStartable kafka = new KafkaServerStartable(kafkaConfig);
    kafka.startup();
}

希望这些帮助:)