小编Jed*_*ina的帖子

Go kafka 的未定义 kafka 组件

我试图安装我的 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
Run Code Online (Sandbox Code Playgroud)

在我的 kafkapublisher.go 文件中,我已经导入了 kafka 依赖项:

    import (
        "github.com/confluentinc/confluent-kafka-go/kafka"
        "log"
    )
Run Code Online (Sandbox Code Playgroud)

即使在我的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
    )
Run Code Online (Sandbox Code Playgroud)

我遵循了这个文档: https: //docs.confluence.io/current/clients/go.html

截屏

go apache-kafka

7
推荐指数
3
解决办法
9685
查看次数

将映射[string]types.AttributeValue解组到特定的业务模型/结构

我正在尝试使用 AWS SDK GO v2: https: //github.com/aws/aws-sdk-go-v2 并且似乎很难解组 dynamodb.GetItemOutput 的 Item 属性,其类型为 map[string]types .属性值。

在 AWS SDK GO v1 中,可以轻松调用dynamodbattribute.UnmarshalMap(result.Item, &data)来解组结果。但在 v2 上,我找不到任何方法来做到这一点。

有人知道该怎么做吗?

aws-sdk-go

5
推荐指数
2
解决办法
4926
查看次数

标签 统计

apache-kafka ×1

aws-sdk-go ×1

go ×1