模拟 Kafka API 进行单元测试

Question

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

Answer 1

producer_test.go在kafka模块中有一个有用的测试生成器：

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

https://github.com/confluenceinc/confluence-kafka-go/blob/master/kafka/ Producer_test.go