有没有办法在没有设置实际代理的情况下测试/模拟 sarama-cluster 的 NewConsumer 功能?我在这里想念什么?
我正在尝试测试的代码:
import cluster "github.com/bsm/sarama-cluster"
func initSaramaConsumer() (*cluster.Consumer, error) {
brokers := []string{"some_url:port"}
groups := "some_group"
topics := []string{"some_topic"}
config := cluster.NewConfig()
saramaConsumer, err := cluster.NewConsumer(
brokers, groups, topics, config,
)
if err != nil {
return nil, err
}
return saramaConsumer, nil
}