用 Kafka API 模拟进行单元测试

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《用 Kafka API 模拟进行单元测试》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我想在 GO 中模拟消费者和生产者的 Confluence Kafka API 进行单元测试，有什么方法（流程/步骤/库）可以成功模拟它们吗？

解决方案

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

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

https://github.com/confluentinc/confluent-kafka-go/blob/master/kafka/producer_test.go

今天关于《用 Kafka API 模拟进行单元测试》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！