尝试使用kafkacat:ssl.ca从本地计算机连接到heroku kafka位置失败：无错误

whitzsjs 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(537)

我尝试按照以下说明使用kafkacat本地连接到我的heroku kafka：https://gist.github.com/crcastle/cb21c2148fc57ad89753bf28b561d910
我正在创建一个env文件，如下所示：

heroku config -s > .env

然后运行这个脚本


# ! /usr/bin/env bash

set -e

source .env

kafkacat -C -t ${KAFKA_PREFIX}test-topic -b $KAFKA_URL \
-X security.protocol=ssl \
-X ssl.key.location=<(echo $KAFKA_CLIENT_CERT_KEY) \
-X ssl.ca.location=<(echo $KAFKA_TRUSTED_CERT) \
-X ssl.certificate.location=<(echo $KAFKA_CLIENT_CERT)

然后我得到这个错误：

% ERROR: Failed to create producer: ssl.ca.location failed: No error

有趣的是，它说生产者，即使我试图消费。
我可以使用

heroku kafka:topics:write test-topic "test 1"

和

heroku kafka:topics:tail test-topic

apache-kafka heroku kafkacat

来源：https://stackoverflow.com/questions/50515509/trying-to-connect-to-heroku-kafka-from-local-computer-using-kafkacat-ssl-ca-loc

1条答案

按热度按时间

btqmn9zl1#

在osx上，我不认为 <(...) 支持语法。尝试：

heroku config:get KAFKA_TRUSTED_CERT -a my-app > $PWD/ca.pem
heroku config:get KAFKA_CLIENT_CERT -a my-app > $PWD/cert.pem
heroku config:get KAFKA_CLIENT_CERT_KEY -a my-app > $PWD/cert.key
export KAFKA_URL="$(heroku config:get KAFKA_URL -a my-app | sed 's/kafka\+ssl\:\/\///g')"
export TOPIC="my-topic"

kafkacat -C -t $TOPIC -b $KAFKA_URL \
-X security.protocol=ssl \
-X ssl.key.location=$PWD/cert.key \
-X ssl.ca.location=$PWD/ca.pem \
-X ssl.certificate.location=$PWD/cert.pem

赞(0）回复(0）举报 2021-06-07

我来回答

尝试使用kafkacat:ssl.ca从本地计算机连接到heroku kafka位置失败：无错误

1条答案

相关问题

热门标签

最新问答