草庐IT

NewConsumer

全部标签

go - 在 sarama-cluster 中模拟 NewConsumer

有没有办法在不设置实际代理的情况下测试/模拟sarama-cluster的NewConsumer函数?我在这里缺少什么?我要测试的代码:importcluster"github.com/bsm/sarama-cluster"funcinitSaramaConsumer()(*cluster.Consumer,error){brokers:=[]string{"some_url:port"}groups:="some_group"topics:=[]string{"some_topic"}config:=cluster.NewConfig()saramaConsumer,err:=clu

go - 在 sarama-cluster 中模拟 NewConsumer

有没有办法在不设置实际代理的情况下测试/模拟sarama-cluster的NewConsumer函数?我在这里缺少什么?我要测试的代码:importcluster"github.com/bsm/sarama-cluster"funcinitSaramaConsumer()(*cluster.Consumer,error){brokers:=[]string{"some_url:port"}groups:="some_group"topics:=[]string{"some_topic"}config:=cluster.NewConfig()saramaConsumer,err:=clu