Go连接Kafka的问题？

一分耕耘，一分收获！既然打开了这篇文章《Go连接Kafka的问题？》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

问题内容

首先我使用了

package kfk

import (
    "github.com/confluentinc/confluent-kafka-go/kafka"
    "strings"
    "sync"
)

type Pool struct {
    brokers []string
    config  *kafka.ConfigMap
    pool    chan *kafka.Producer
    wg      sync.WaitGroup
}

var (
    KafkaPool *Pool
)

func KfkInit() {
    poolSize := 10
    brokers := []string{"localhost:9092"}
    KafkaPool = NewPool(brokers, poolSize)
}

// 初始化连接池
func NewPool(brokers []string, poolSize int) *Pool {
    config := &kafka.ConfigMap{
        "bootstrap.servers":   strings.Join(brokers, ","),
        "acks":                "all",
        "delivery.timeout.ms": 3000,
    }

    p := &Pool{
        brokers: brokers,
        config:  config,
        pool:    make(chan *kafka.Producer, poolSize),
    }

    for i := 0; i 

开发完之后，我打算执行

#!/bin/bash

swag init >/dev/null 2>&1
# 根据不同的平台进行交叉编译

echo "$(date +"%Y-%m-%d %H:%M:%S") Success: Swag生成成功，正在执行打包···"

# save the original values of GOOS and GOARCH
GOOS_ORIGINAL=$(go env GOOS)
GOARCH_ORIGINAL=$(go env GOARCH)

# specify the target platform and architecture
platform=${1:-"linux"}
arch=${2:-"amd64"}

# set the environment variables for the target platform and architecture
if [ "$platform" == "linux" ] && [ "$arch" == "amd64" ]; then
    export GOOS=linux
    export GOARCH=amd64
elif [ "$platform" == "windows" ] && [ "$arch" == "amd64" ]; then
    export GOOS=windows
    export GOARCH=amd64
else
    echo "Error: Unsupported platform and architecture combination"
    exit 1
fi

# build the Go binary for the target platform and architecture
go build -o dot_production main_production.go

# check if the binary was successfully built
if [ $? -eq 0 ]; then
    echo "$(date +"%Y-%m-%d %H:%M:%S") Success: ${GOOS} 生产者 平台打包完成！"
else
    echo "$(date +"%Y-%m-%d %H:%M:%S") Success: ${GOOS} 生产者 平台打包失败！"
    exit 1
fi

go build -o dot_consumer main_consumer.go

# check if the binary was successfully built
if [ $? -eq 0 ]; then
    echo "$(date +"%Y-%m-%d %H:%M:%S") Success: ${GOOS} 消费者 平台打包完成！"
else
    echo "$(date +"%Y-%m-%d %H:%M:%S") Success: ${GOOS} 消费者 平台打包失败！"
    exit 1
fi

# reset the GOOS and GOARCH environment variables to their original values
export GOOS=$GOOS_ORIGINAL
export GOARCH=$GOARCH_ORIGINAL

报错如下：

zxx@Macbook dot % ./pack.sh 
2023-06-03 00:31:29 Success: Swag生成成功，正在执行打包···
# dot/middleware/kfk
middleware/kfk/kfk_consumer.go:18:22: undefined: kafka.ConfigMap
middleware/kfk/kfk_consumer.go:19:22: undefined: kafka.Consumer
middleware/kfk/kfk_consumer.go:26:19: undefined: kafka.ConfigMap
middleware/kfk/kfk_consumer.go:39:25: undefined: kafka.NewConsumer
middleware/kfk/kfk_consumer.go:56:2: maxMessages declared and not used
middleware/kfk/kfk_production.go:11:17: undefined: kafka.ConfigMap
middleware/kfk/kfk_production.go:12:22: undefined: kafka.Producer
middleware/kfk/kfk_production.go:53:41: undefined: kafka.Producer
middleware/kfk/kfk_production.go:63:37: undefined: kafka.Producer
middleware/kfk/kfk_production.go:68:48: undefined: kafka.Producer
middleware/kfk/kfk_consumer.go:56:2: too many errors
2023-06-03 00:31:29 Success: linux 生产者 平台打包失败

十分不理解，这是什么原因呢？换成kafka之后，不能进行交叉编译么？请各位大佬赐教~ 各位大佬辛苦

正确答案

首先，我并不是很确定问题的原因，因为确实没用过这个库，我只能说一些可能存在的问题：

1. 修改 import 为 v2 ，可能由于老版本存在问题

   import (
    "github.com/confluentinc/confluent-kafka-go/v2/kafka"
   )

2. 编译Linux时尝试添加 tags
   If you are building for Alpine Linux (musl), -tags musl must be specified.

   go build -tags musl ./...

3. 尝试使用下面的方式进行编译（我认为最可能的问题）

   $ export CC=aarch64-linux-gnu-gcc ; GOOS=linux GOARCH=arm64 CGO_ENABLED=1 go build -v  -ldflags="-extld=$CC"

   https://github.com/confluentinc/confluent-kafka-go/issues/947

本篇关于《Go连接Kafka的问题？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！