blocks|key|582030|text|我已经弄明白这个了。我安装了Confluent的Kafka+Go客户端。说明在这里：https://docs.confluent.io/current/clients/go.html#|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|582031|但是windows不支持这个库，所以我不得不使用虚拟机(Oracle+VM+Box)来构建和运行我的代码。|582032|在安装Confluent的GO+Kafka客户端之前，我还需要编译和安装librdkafka：https://github.com/confluentinc/confluent-kafka-go/blame/master/README.md#L133|582033|谢谢。|582034|entityMap|0|LINK|mutability|MUTABLE|url|https://docs.confluent.io/current/clients/go.html#|1|https://github.com/confluentinc/confluent-kafka-go/blame/master/README.md#L133^0|16|1E|0|0|0|1B|26|1|0|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@$A|U|B|V|1|W]]|C|$]]|$1|D|3|E|5|6|7|X|8|@]|9|@]|C|$]]|$1|F|3|G|5|6|7|Y|8|@]|9|@$A|Z|B|10|1|11]]|C|$]]|$1|H|3|I|5|6|7|12|8|@]|9|@]|C|$]]|$1|J|3|-4|5|6|7|13|8|@]|9|@]|C|$]]]|K|$L|$5|M|N|O|C|$P|Q]]|R|$5|M|N|O|C|$P|S]]]]

I already figured out this one. I installed Confluent's Kafka Go Client.
Instructions are here: <a href="https://docs.confluent.io/current/clients/go.html#" rel="nofollow noreferrer">https://docs.confluent.io/current/clients/go.html#</a>

The library is not supported on windows though, so I had to use virtual machine (Oracle VM Box) to build and run my code.

I also needed to compile and install librdkafka before installing the Confluent's GO Kafka Client: <a href="https://github.com/confluentinc/confluent-kafka-go/blame/master/README.md#L133" rel="nofollow noreferrer">https://github.com/confluentinc/confluent-kafka-go/blame/master/README.md#L133</a>

Thanks.

blocks|key|892111|text|我也面临着同样的问题。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|892112|Kafka+Go客户端是基于C库的。因此，设置标志CGO_ENABLED=1将使go能够为kafka客户端使用C库。|offset|length|style|CODE|892113|希望这能节省一些人的时间。|892114|entityMap^0|0|P|D|0|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|M|8|@$D|N|E|O|F|G]]|9|@]|A|$]]|$1|H|3|I|5|6|7|P|8|@]|9|@]|A|$]]|$1|J|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|K|$]]

I was facing the same issues.
Kafka Go client is based on the C library. So setting flag <code>CGO_ENABLED=1</code> will enable go to use C libraries for kafka client.
Hope it saves someone's time.

blocks|key|4365314|text|显然，依赖项没有被导入，|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4365315|如果您运行go+build命令，它将下载必要的依赖项并编译代码等|4365316|尝试运行go+build+./...|offset|length|style|CODE|4365317|entityMap^0|0|0|4|E|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|M|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|N|8|@$F|O|G|P|H|I]]|9|@]|A|$]]|$1|J|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|K|$]]

clearly dependencies are not being imported, 

if you run the go build command, it will download the necessary dependencies and compile the code etc

try running <code>go build ./...</code>

blocks|key|581977|text|依赖项尚未下载。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|581978|您可以使用go+get来下载该包。或使用|offset|length|style|BOLD|581979|581980|go+mod+download|ordered-list-item|581981|go+mod整洁|581982|go+mod供应商-这将创建一个供应商文件夹，其中包含所需的依赖项|581983|581984|entityMap^0|0|5|6|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|T|8|@$D|U|E|V|F|G]]|9|@]|A|$]]|$1|H|3|-4|5|6|7|W|8|@]|9|@]|A|$]]|$1|I|3|J|5|K|7|X|8|@]|9|@]|A|$]]|$1|L|3|M|5|K|7|Y|8|@]|9|@]|A|$]]|$1|N|3|O|5|K|7|Z|8|@]|9|@]|A|$]]|$1|P|3|-4|5|6|7|10|8|@]|9|@]|A|$]]|$1|Q|3|-4|5|6|7|11|8|@]|9|@]|A|$]]]|R|$]]

The dependencies have not been downloaded.

You can either use a go get to download the package.
Or Use 

<ol>
<li>go mod download</li>
<li>go mod tidy</li>
<li>go mod vendor - This will create a vendor folder with the required dependencies</li>
</ol>

blocks|key|2898379|text|在构建镜像时，请使用-tags+musl+(对于高山linux，@请参阅github.com/confluentinc/confluent-+Kafka+-+Go+)和active+CGO_ENABLED来激活C语言中的lib，因为Kafka+Go客户端基于C库库Kafka|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|2898380|在dockerfile中：|2898381|FROM+golang:1.16-alpine+as+builder

ARG+GIT_TAG_NAME

RUN+apk+--no-cache+update+&&+\
apk+--no-cache+add+git+gcc+libc-dev

#+Kafka+Go+client+is+based+on+the+C+library+librdkafka
ENV+CGO_ENABLED+1
ENV+GOFLAGS+-mod=vendor
ENV+GOOS=linux
ENV+GOARCH=amd64

RUN+export+GO111MODULE=on

RUN+go+build+-tags+musl+-ldflags+"-s+-w+-X+main.Version=$GIT_TAG_NAME"+-o+bin/main+./cmd/main|code-block|syntax|javascript|2898382|注意：-标签musl：如果你想使用内置的librdkafka+-标签动态：如果你想使用你自己的librdkafka。|BOLD|2898383|entityMap^0|A|A|2J|B|0|0|0|4|6|W|4|0^^$0|@$1|2|3|4|5|6|7|R|8|@$9|S|A|T|B|C]|$9|U|A|V|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|W|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|X|8|@]|D|@]|E|$K|L]]|$1|M|3|N|5|6|7|Y|8|@$9|Z|A|10|B|O]|$9|11|A|12|B|O]]|D|@]|E|$]]|$1|P|3|-4|5|6|7|13|8|@]|D|@]|E|$]]]|Q|$]]

When you build your image, use <code>-tags musl</code> (for alpine linux, @see github.com/confluentinc/confluent-kafka-go) and active <code>CGO_ENABLED</code> to activate lib in C because Kafka Go client is based on the C library librdkafka
In dockerfile :
<pre><code>FROM golang:1.16-alpine as builder

ARG GIT_TAG_NAME

RUN apk --no-cache update &amp;&amp; \
apk --no-cache add git gcc libc-dev

# Kafka Go client is based on the C library librdkafka
ENV CGO_ENABLED 1
ENV GOFLAGS -mod=vendor
ENV GOOS=linux
ENV GOARCH=amd64

RUN export GO111MODULE=on

RUN go build -tags musl -ldflags &quot;-s -w -X main.Version=$GIT_TAG_NAME&quot; -o bin/main ./cmd/main
</code></pre>
Note:
-tags musl : if you want to use the built-in librdkafka
-tags dynamic : if you want to use your own librdkafka.

I was trying to install one of my go files. But I bumped into this error
<pre><code>C:\mygoproject&gt;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
</code></pre>
On my kafkapublisher.go file, I already imported the kafka dependency:
<pre><code> import (
 &quot;github.com/confluentinc/confluent-kafka-go/kafka&quot;
 &quot;log&quot;
 )
</code></pre>
even on my <code>go.mod</code> file
<pre><code> module mymodule
 
 go 1.12
 
 require (
 github.com/aws/aws-lambda-go v1.15.0
 github.com/confluentinc/confluent-kafka-go v1.3.0
 )
</code></pre>
I followed this documentation: <a href="https://docs.confluent.io/current/clients/go.html" rel="nofollow noreferrer">https://docs.confluent.io/current/clients/go.html</a>
<a href="https://i.stack.imgur.com/2SXEP.png" rel="nofollow noreferrer">screenshot</a>

undefined kafka components for Go kafka

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

我在试着安装我的一个go文件。但是我遇到了这个错误C:\mygoproject>go install kafkapublisher.go\#command-line-arguments.\kafkapublisher.go:8:65: undefined: kafka.Message.\kafkapublisher.go:10:19: undefined: kafka.NewProducer.\k

问Go kafka的未定义kafka组件
EN

回答 5

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Go kafka的未定义kafka组件EN

回答 5

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Go kafka的未定义kafka组件
EN