更新:原来我在Docker中的端口有问题。不确定为什么会解决此现象。我相信我遇到了一个奇怪的错误。我正在使用Sarama库并能够成功创建消费者。funcmain(){config=sarama.NewConfig()config.ClientID="go-kafka-consumer"config.Consumer.Return.Errors=true//Createnewconsumermaster,err:=sarama.NewConsumer("localhost:9092",config)iferr!=nil{panic(err)}deferfunc(){iferr:=mast

我关注了一个excellentstep-by-steptutorialforinstallingKafkaonLinux.在我重新启动Linux之前，一切对我来说都很好。重启后，当我尝试使用kafka-console-consumer.sh消费队列时出现以下错误。$~/kafka/bin/kafka-console-consumer.sh--zookeeperlocalhost:2181--topicTutorialTopic--from-beginning[2016-02-0403:16:54,944]WARN[console-consumer-6966_bob-kafka-stor