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下载软件包。或使用去模组下载去整理一下go mod vendor - 这将创建一个包含所需依赖项的供应商文件夹

Answer 3

我也面临同样的问题。Kafka Go 客户端基于 C 库。因此，设置标志CGO_ENABLED=1将使 go 能够为 kafka 客户端使用 C 库。希望它可以节省某人的时间。