Go kafka 的未定义 kafka 组件

Question

我试图安装我的一个 go 文件。但是我遇到了这个错误C:\mygoproject>go install kafkapublisher.go\#command-line-arguments.\kafkapublisher.go:8:65: undefined: kafka.Message.\kafkapublisher.go:10:19: undefined: kafka.NewProducer.\kafkapublisher.go:10:38: undefined: kafka.ConfigMap.\kafkapublisher.go:17:31: undefined: kafka.Event.\kafkapublisher.go:19:26: undefined: kafka.Message在我的 kafkapublisher.go 文件中，我已经导入了 kafka 依赖项：    import (        "github.com/confluentinc/confluent-kafka-go/kafka"        "log"    )甚至在我的go.mod档案上    module mymodule        go 1.12        require (        github.com/aws/aws-lambda-go v1.15.0        github.com/confluentinc/confluent-kafka-go v1.3.0    )我遵循了这个文档：https ://docs.confluent.io/current/clients/go.html

Answer 1

我已经想通了这个。我安装了 Confluent 的 Kafka Go 客户端。说明在这里：https ://docs.confluent.io/current/clients/go.html#

虽然 Windows 不支持该库，但我不得不使用虚拟机（Oracle VM Box）来构建和运行我的代码。

在安装 Confluent 的 GO Kafka 客户端之前，我还需要编译和安装 librdkafka：https ://github.com/confluentinc/confluent-kafka-go/blame/master/README.md#L133

谢谢。

Answer 2

依赖项尚未下载。

您可以使用go get下载软件包。或使用

1. 去模组下载

2. 去整理一下

3. go mod vendor - 这将创建一个包含所需依赖项的供应商文件夹

Answer 3

我也面临同样的问题。

Kafka Go 客户端基于 C 库。因此，设置标志CGO_ENABLED=1将使 go 能够为 kafka 客户端使用 C 库。

希望它可以节省某人的时间。