我们正计划在kubernetes上设置Kafka和zookeeper，Zookeeper工作正常，但在设置Kafka时，kafka给出了问题，Kafka无法与zookepeer通信。我们正在计划设置内部负载均衡器来与外部世界通信，我们如何通信。请参考以下文件：---kind: Service name: kafka
namesp
浏览 21提问于2018-01-20得票数 1
我正在关注(至少尝试)这个卡夫卡快速入门文档Kafka quickstart 在执行Kafka和Zookeeper服务器启动时，它们都会导致以下错误： [0.003s][error][logging]Error opening log file '/c/Users/Manol/Downloads/kafka_2.13-2.7.0/kafka_2.13-2.7.0/bin/..No such file or direc
浏览 54提问于2021-03-06得票数 2
我无法启动Zookeper。我已经尝试删除文件夹，从头开始重新开始，也尝试更改目录。但是，我在CMD中得到了以下错误：'Kafka\kafka_2.11-1.0.0\bin\windows\..' is not recognized a
浏览 3提问于2017-11-06得票数 0
回答已采纳
我的kafka代理说正在等待连接到zookeper，然后关机(超时)，.I检查了代理的配置/端口，做了netstat等也确认了zookeper的设置。但是，如果我重新启动我的ubuntu内核(运行kafka broker的地方)，一切都是正常的。Zookeeper在Linux mint上。请告诉我哪些日志文件可以给我更多的细节-我做了通常的</e
浏览 0提问于2021-03-19得票数 0
1回答
我正在尝试学习kafka.The zookeper服务器和kafka，并安装在ubuntu aws node.Zookeper服务器上，与三个经纪人和一个消费者一起运行。我在我的maven项目中(在我的笔记本电脑上)使用java客户端(kafka-clients0.9.0.1)将数据发送给亚马逊网络服务上的经纪人和消费者。是否需要在我的本地系统上
浏览 0提问于2016-05-27得票数 0
我有点难以理解这个包含多个"Microsoft.Compute/virtualMachines/extensions“和多个VM的Azure ARM模板：
假设有4个VM :1个用于动物园管理员，3个用于Kafka集群，那么如何确保Zookeper的扩展名(+script)恰好运行在一个Zookeper VM上，以及如何确保Kafka集群的扩展名(+script )将运行在这3个Kafka</e
浏览 1提问于2022-02-08得票数 0
回答已采纳
3回答
我已经在亚马逊EC2实例上设置卡夫卡。如何才能使Kafka服务器为所有请求永久启动，即使在关闭SSH窗口之后也是如此。
谢谢。
浏览 1提问于2013-02-14得票数 24
回答已采纳
当我看到这个错误消息时：
ll /tmp/kafka-logs/drwxrwxr-x 2 ec2-user e
浏览 2提问于2019-04-19得票数 1
回答已采纳
我试着在windows上设置kafka和zookeeper。最初，我创建了主题、生产者和消费者。它工作得很好。然后我使用下面的命令删除了一个主题：现在，每次我重新运行kafka时，它都会终止，并显示以下错误: C:\kafka_2.12-2.8.0\kafka_2.12-
浏览 3提问于2021-05-16得票数 3
1回答
Detail:，我正在尝试使用docker-compose.yml文件运行和映像，该文件附在本文的底部。
为了测试容器，我遵循了。它指的是一些在映像中不可用的脚本，如bin/kafka-server-start.sh。我还尝试使用docker exec -it zookeeper bash和docker exec -it kafka bash遍历容器，并在/bin/目录中找到zkServer.sh和其他一些脚本。所以我不知道正确的<
浏览 1提问于2019-07-03得票数 1
回答已采纳
我正在尝试阅读多个卡夫卡经纪人使用KafkaIO上的阿帕奇光束。偏移量管理的默认选项是kafka分区本身(不再使用kafka >0.9的zookeper )。使用此设置时，当我重新启动作业/管道时，存在重复和缺少记录的问题。
据我所知，处理这个问题的最好方法是管理外部数据存储的偏移量。有没有可能用当前版本的apache和Kafka
浏览 9提问于2017-12-24得票数 0
2回答
卡夫卡动物园管理员安全
、、、
我使用的是Kafka版本0.10.2.0。是否有一种方法来保护Zookeper客户端，即ZkClient和zookeper服务器之间的通信安全。我通过SASL找到了一些方法，但我希望它通过SSL。
浏览 1提问于2017-04-17得票数 3
回答已采纳
我有一些集成测试，可以在@BeforeClass中创建Kafka和Zookeeper的嵌入式实例。有没有可能编写一个JUnit测试运行器来强制关闭所有由测试启动的子线程？
浏览 3提问于2016-11-12得票数 0
我正在试用kafka-console-producer.sh。我在控制台上输入一些东西，然后按回车键，我得到了大量的堆栈跟踪，就像这样。感谢您的指点。.:167) at kafka.utils.Utils$.swallowError:100)
at kafka.producer.SyncProducer
浏览 3提问于2014-11-25得票数 14
回答已采纳
我正面临着一个恼人的问题，希望有人能给我一个提示。ENTRYPOINT ["java", "-jar", "app.jar"]services:
zookeper:image: wurstmeister/ka
浏览 2提问于2021-10-15得票数 0
回答已采纳
我们有3台卡夫卡机器和3台动物园服务器。虽然kafka机器不是与zookeper服务器共同托管的( kafka在不同的机器上，OS是红帽子版本7.x )cd /usr/hdp/current/zkCli.sh
结果应该是三个经纪人的身份证
1011 1012
浏览 2提问于2018-10-01得票数 0
回答已采纳
我试图用下面的配置使用docker运行几个容器：services: kafka: container_name: kafka - ADVERTISED_HOST=localhost - kafka:<e
浏览 0提问于2020-03-27得票数 0
回答已采纳
1回答
我的TCP nginx configmap看起来像 "<zookeper-tcp-port>": <namespace>/cp-zookeeper:2181我在我的nginx入口控制器中做了相应的条目
- name: <zookeper-tc
浏览 2提问于2020-04-08得票数 1
回答已采纳
我试图在Kubernetes中设置一个Kafka pod，但是我一直收到这个错误：这是我的Kafka部署：kind: Deployment name: kafka这是我的Kafka服务：
a
浏览 0提问于2020-08-30得票数 0
我使用以下脚本在docker网络中建立了CDC管道-始终重新启动\ /var/ibank/msdata/test/zookeper/config/zoo.cfg:/zookeper/conf//data/txns:/zookeper/txns \ -v /var/ibank/msdata/测试/动物园/数据/日志:/
浏览 4提问于2021-10-12得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号