模拟 Kafka API 以进行单元测试答案

【问题标题】：Mocking Kafka APIs for Unit Testing模拟 Kafka API 以进行单元测试
【发布时间】：2020-04-06 13:44:24
【问题描述】：

我想在 GO 中模拟 Confluent Kafka APIs for Consumer 和 Producer 以进行单元测试，有什么方法（流程/步骤/库）可以成功模拟它们吗？

【问题讨论】：

您找到解决方案了吗？
是的。您应该能够通过简单地在现有应用程序中配置 test.mock.num.brokers=3 来使用生产者应用程序在阳光场景测试（即消息将成功生成）中按原样使用它。从图书馆找到的。

【解决方案1】：

kafka 模块中的producer_test.go 有一个有用的测试生产者：

p, err := NewProducer(&ConfigMap{
    "socket.timeout.ms":  10,
    "message.timeout.ms": 10})

【讨论】：