如何实现作为消费者读取kafka消息的自动测试

Question

我需要为一个与Kafka集成并向远程Kafka服务器发送事件消息的应用程序编写测试。作为消费者，我的目标是确保创建这些消息，并在可能的情况下检查其内容。

我查阅了Kafka文档，发现消费者API是我应该开始的地方，但我不确定如何开始实现它

Answer 1

如果你想远离编程，你可以配置Mockintosh的"验证消费者"；(https://mockintosh.io/Async.html#validating-消费者(。

然后，您可以验证通过对Mockintosh API的简单HTTP调用创建的消息的事实。此外，还有一个用户界面可以查看这些消息。