我正在尝试使用shell脚本文件在Docker中运行的Kafka容器中创建一个主题。/bin/zshdocker exec kafka kafka-topics --create --bootstrap-server localhost:29092--partitions 1 --r
浏览 111提问于2021-11-04得票数 0
回答已采纳
1回答
我在Windows 10上安装了Docker，也安装了Kafka。我在一个卡夫卡集群中创建了一个“测试”主题。现在，我想用一个简单的用户名和密码来保护这个主题。我是卡夫卡的新手，任何帮助都会很感激。为了运行Kafka命令，我使用了windows "Power Shell“。
我试过在命令行上运行一些命令。To create Topics:- kafka<
浏览 2提问于2019-10-23得票数 0
我正在尝试将Kafka主题连接到我的前端attempting应用程序。我正在利用码头写作，并试图连接使用两种不同的卡夫卡图像。有了，我就能够在docker.compose.yml文件中通过这个服务来启动和运行Kafka主题。但是，我无法将创建的主题连接到我的前端Java应用程序。- /var/run/docker.sock:/var/run/
浏览 7提问于2017-08-07得票数 7
我已经使用docker在本地部署了kafka服务。docker-compose文件如下所示：image: confluentinc/cp-kafka:5.4.0 - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-serv
浏览 2提问于2020-02-06得票数 0
Kafka主题可以通过命令行工具或API创建。
在有多个主题和多个环境(dev/qa/prod等)的大型系统中有必要控制主题的创建及其配置(分区等)。例如，我们可能希望在源代码管理下维护一个shell脚本文件，该文件检查主题是否已经存在，如果不存在，则创建它。然后，可以将相同的脚本应用于每个后续环境(可能会自
浏览 0提问于2017-05-16得票数 0
我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用托管在上的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么也不会发生，程序就会卡住。我猜producer.send无法连
浏览 2提问于2017-02-03得票数 1
我希望我的shell脚本的集成测试等待直到卡夫卡起来。我尝试使用这个命令从Kafka获取主题，但它甚至在Docker显示[KafkaServer id=1001] started (kafka.server.KafkaServer)之前就已经报道过了。也许是从动物园管理员那里读到的，而不是卡夫卡。docker start queue-service-kafka &&
浏览 1提问于2018-12-06得票数 1
回答已采纳
6回答
码头工创作卡夫卡主题
、、、、
Problem：无法从坞撰写创建主题。在运行测试系统之前，我需要创建kafka主题。计划使用它作为管道的一部分，因此使用UI不是一个选项。可能的解决方案
在启动所测试的系统之前，将该坞映像包括在docker-com
浏览 3提问于2020-11-16得票数 21
3回答
因此，我编写了一个Dockerfile，其中ENTRYPOINT为上面的序列执行一个shell脚本：但是，在运行基于此构建的docker映像时，我遇到了三个问题：
Docker要求ENTRYPOINT进程长时间运行，而上面的脚本不需要。(只要主题创建完成，它就会存
浏览 6提问于2017-10-12得票数 3
回答已采纳
然后，我创建了一个简单的groovy脚本客户端生成器来编写一些条目，但是这会导致错误 Properties props = new Properties()
props.put("bootstrap.servers", "192.168.1.89假设我已经将kafka服务器旋转为docker容
浏览 3提问于2017-01-29得票数 2
我想创造一个卡夫卡-主题从火花集群。我注意到创建了一个我们需要调用Kafka-topics.sh的主题，这个主题在星火集群中是不可用的。命令应该通过shell调用。/kafka_topics.sh --动物园管理员:2181 -创建主题test_topic
这个脚本应该从spark集群调用，并且应该在Kafka集群上执行。有谁可以帮我？
浏览 2提问于2016-09-12得票数 0
回答已采纳
我们在Docker容器中使用Kafka。当生产或消费消息时，如果主题不存在，我们会自动创建主题。我们想要3个主题分区，所以设置在Kafka容器的/etc/kafka/server.properties文件中。但是，它不会生效。完成设置并重新启动容器后，尝试订阅或发布一些不存在的主题，主题</
浏览 2提问于2020-07-28得票数 0
我已经创建了一个docker组合文件，我的应用程序想要在其中使用kafka。docker-compose.yaml是： api: - kafka192.168.1.7是我从ifconfig获得的ip
浏览 1提问于2020-08-06得票数 0
我正在尝试从命令行创建一个新的Kafka主题我得到了错误从文档中，我看到设置num.partitions应该已经完成了这项工作。此外，我想知道只连接到zookeeper而不带任何参数到server
浏览 0提问于2018-02-26得票数 17
回答已采纳
通过kafka-console-producer.bat发送到localhost时不创建消息，错误消息为： - KAFKA_ADVERTISED_LISTENERS=DOCKER_INTE
浏览 1提问于2019-09-12得票数 0
任何人都可以帮助我消耗连续数据中的数据，这些数据正在被流式传输。在snowflake连接器中应该为主题提供什么？
因为我能够使用所需的主题名称通过单个表数据填充数据。但我有捕获连续数据流到表中的要求。
浏览 0提问于2021-10-07得票数 5
我正在尝试为没有ssl的Kafka集群启用SASL用户名和密码。我遵循了Stackoverflow上的步骤： Kafka SASL zookeeper authentication SASL身份验证似乎对Kafka经纪人有效。在写入或读取主题之前，消费者和生产者必须进行身份验证。到目前一切尚好。 问题是在kafka上创建和删除主题。例如，当我尝试使用以下命令时： ~/kafka/bin/
浏览 45提问于2019-02-28得票数 0
我正在尝试为卡夫卡主题设置docker图像。这是我的docker-compose.yml文件中的内容 version: '2'
hostname: kafka</
浏览 33提问于2020-11-11得票数 0
volumes:当我试图通过输入shell内部创建一个主题时，它会抛出下面的错误。/start- kafka -shell.sh .start zookeeper:2181
bash-4.4# $KAFKA_HOME/bin/kafka-topi
浏览 0提问于2019-02-12得票数 3
2回答
到目前为止，我已经创建了两台带有以下命令的对接机器，一个是管理员，另一个是工作人员：docker-machine create worker1然后使用命令docker stack deploy -c docker-compose.yml kafka进行部署，该命令返回Creating/tcp
然后，我使用docker
浏览 6提问于2020-01-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
