如何在 Kafka Go 中编写单元测试答案

【问题标题】：How to write unit tests in Kafka go如何在 Kafka Go 中编写单元测试
【发布时间】：2022-01-24 16:53:36
【问题描述】：

在 golang 中为 Kafka 编写单元测试的正确方法是什么？

在 java 中，对于 Kafka 流，我们有 Kafka 流测试，直到简化测试用例的编写。

但是，我无法在 Kafka for golang 中找到类似的东西。

关于如何使用 docker 容器调出 Kafka 并测试 E2E 流程，有几篇不错的文章。但我真的在寻找带有模拟服务器的单元测试。

我正在使用 confluent kafka go

【问题讨论】：

【解决方案1】：

不清楚您要查找的库。 Sarama 有一个可以使用的 mocks 包https://github.com/Shopify/sarama/tree/main/mocks

你不模拟服务器，只模拟客户端之间的数据

【讨论】：