我想在我的docker中安装一个kafka镜像,我已经尝试过,但是当我在命令行docker pull wurstmeister/kafka中写入时,我得到了这个错误:
/bin/sh: 1: /tmp/download-kafka.sh: Permission denied
Service 'kafka' failed to build: The command [/bin/sh -c /tmp/download-kafka.sh] returned a non-zero code: 126
有人知道问题出在哪里吗?
我正在开发一个使用Nuget包的.NET核心应用程序-- Confluent.Kafka,版本0.11.3
我使用它来实例化一个Producer,然后调用myProducer.ProduceAsync方法。我在应用程序日志中看到一个错误,声明为- Unable to find an entry point named 'rd_kafka_producev' in shared library 'librdkafka'。
我在一个运行Debian v9的容器中运行Kafka。运行使用.NET的Kafka核心应用程序的docker容器安装了librdkafka1 -
我可以使用docker设置Kafka,但是当我尝试使用python访问它时,我无法做到这一点。如果我在kafka shell中安装python,我可以做到这一点,但在kafka shell之外和docker python内部,我无法使用kafka。
我的Producer.py文件:
import time
import random
from kafka import KafkaProducer
# give broker IP from docker
producer = KafkaProducer(bootstrap_servers='kafka:9092')
# co
我正在尝试使用kafka-docker:。Docker在我每次启动服务时都会为kafka代理设置一个新的端口。这意味着,32781、32782和32783每次都会发生变化。
$ docker container ls
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
c9e2188366cb wu
在运行docker-compose up -d时,我会得到以下错误
% docker-compose up -d
Creating network "kafka-test_default" with the default driver
Creating kafka-test_zoo1_1 ... error
ERROR: for kafka-test_zoo1_1 Cannot start service zoo1: Mounts denied: approving /Users/test/kafka-test/zk-single-kafka-single/zoo1/d
我刚接触docker,在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序,生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行,但当我尝试通过主机上的docker容器运行它时,会出现以下错误:
org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not
30000ms.it显示错误后卡夫卡连接超时
{ TimeoutError: Request timed out after 30000ms
at new TimeoutError (/app/node_modules/kafka-node/lib/errors/TimeoutError.js:6:9)
at Timeout.timeoutId._createTimeout [as _onTimeout] (/app/node_modules/kafka-node/lib/kafkaClient.js:1007:14)
at listOnTimeout (internal/timers.js: