在golang中为Kafka编写单元测试的正确方法是什么？
在java中，对于Kafka流，我们有Kafka测试，直到这简化了测试用例的编写。
然而，我在卡夫卡中找不到戈朗的相似之处。
关于如何使用docker容器来调用Kafka和测试E2E流，有一些不错的文章。但我确实在寻找使用模拟服务器的单元测试。
我正在使用合流kafka go
不清楚您要查找的库。Sarama有一个可以使用的模拟包https://github.com/Shopify/sarama/tree/main/mocks
您不模拟服务器，只模拟客户端之间的数据传递
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium