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

Question

我需要为与 Kafka 集成并将事件消息发送到远程 Kafka 服务器的应用程序编写测试。作为消费者，我的目标是确保创建这些消息并检查其内容（如果可能的话）。

我查看了 Kafka 文档，发现 consumer API 是我应该开始的地方，但我不确定如何开始实施它。

Answer 1

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

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