我花了很多时间去找类似的东西 org.apache.kafka.clients.producer.MockProducer<K,V> 在.net内核中。
我必须为我们的一个内部消费者编写一些单元测试，我对此有问题。
mockproducer会帮我生成消息，然后我就可以运行了 consume() 方法。