Tag: kafka

Python 连接 AWS MSK 并生产消息

Jackey Python 105 次浏览 ,
使用库:github.com/aws/aws-msk-iam-sasl-signer-python 安装方式参考:github.com/aws/aws-msk-iam-sasl-signer-python/blob/main/docs/installation.rst 最终代码: #!/usr/bin/python3 from kafka import KafkaProducer...

Golang 推送消息到 kafka(生产者)

Jackey Golang 4,211 次浏览 ,
配置相关依赖包: [codesyntax lang="bash"] mkdir -p $GOPATH/src/golang.org/x cd $GOPATH/src/golang.org/x git clone https://github.com/golang/net.git git clone https://github.com/golang/crypto.git go get github....
Go