Tag: sarama

在部署到Docker的情况下，在Golang中实现的Apache Kafka消费者恐慌

这里是我尝试实现一个简单的微服务，它应该读取来自kafka服务器的消息并通过HTTP发送。 它运行正常，当我从terminal运行它，但是当部署在泊坞窗上它恐慌 panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x1 addr=0x40 pc=0x7b6345] goroutine 12 [running]: main.kafkaRoutine.func1(0xc420174060, 0x0, 0x0) /go/src/github.com/deathcore666/ProperConsumerServiceYo/kafka.go:36 +0x95 created by main.kafkaRoutine /go/src/github.com/deathcore666/ProperConsumerServiceYo/kafka.go:32 +0x1ad kafka.go第32行和第36行是go func(pc sarama.PartitionConsumer)函数的地方。 我对编程相对较新，所以任何帮助，将不胜感激。 谢谢！ main.go： func main() { var ( listen = flag.String("listen", ":8080", "HTTP listen address") proxy = flag.String("proxy", "", "Optional […]