我想在 GO 中模拟 Confluent Kafka APIs for Consumer 和 Producer 进行单元测试，有没有办法(流程/步骤/库)成功模拟它们？
最佳答案
producer_test.go在 kafka 模块中有一个有用的测试生产者:
p, err := NewProducer(&ConfigMap{
"socket.timeout.ms": 10,
"message.timeout.ms": 10})
关于unit-testing - 模拟 Kafka API 以进行单元测试，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59316913/