卡夫卡中Zookeeper的用途
是作为分布式协调服务，用于管理和协调Kafka集群中的各个节点。具体来说，Zookeeper在Kafka中扮演以下几个角色：
- 配置管理：Zookeeper负责存储和管理Kafka集群的配置信息，包括主题（topic）的分区（partition）分配、副本（replica）的分配等。通过Zookeeper，Kafka集群中的各个节点可以实时获取最新的配置信息。
- 集群管理：Zookeeper维护了Kafka集群的整体状态，包括集群中的所有节点的存活状态、节点的上下线等。当有新的节点加入或节点离开时，Zookeeper会通知其他节点进行相应的调整。
- Leader选举：Kafka集群中的每个分区都有一个Leader节点负责处理读写请求，而其他节点则作为副本节点备份数据。当Leader节点发生故障或离线时，Zookeeper会协助进行新的Leader选举，确保集群的高可用性。
- 消费者组管理：Kafka支持以消费者组（consumer group）的方式进行消息消费，Zookeeper负责管理和协调消费者组的消费进度。消费者组的消费进度信息会被存储在Zookeeper中，以便在消费者发生故障或重新加入时能够继续消费未处理的消息。
- 通知机制：Zookeeper提供了事件通知机制，可以实时通知Kafka集群中的各个节点发生的变化。这样，Kafka节点可以根据这些通知及时做出相应的调整，保证集群的一致性和可用性。
腾讯云提供了一款与Kafka相关的产品，即消息队列 CKafka。CKafka是腾讯云自研的分布式消息队列产品，完全兼容Kafka协议，提供高可用、高吞吐量、低延迟的消息队列服务。您可以通过腾讯云CKafka产品介绍页面（https://cloud.tencent.com/product/ckafka）了解更多相关信息。
相关·内容
卡夫卡已经部署在码头集装箱里了。
version: '3.8'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
KAFKA_ZOOKEEPER_CON
浏览 5提问于2022-08-10得票数 0
回答已采纳
2回答
我试图连接我的卡夫卡容器和我的码头形象所有运行在本地，不想创建一个容器与卡夫卡和动物园管理员的形象。
当我运行这个应用程序时，没有对它进行修改，它运行得很好。
运行dockerize应用程序后，docker日志将显示
could not read message dial tcp 172.21.0.3:9092: i/o timeout
在卡夫卡日志中，它显示了
kafka-zookeeper-1 | 2021-12-07 06:17:15,755 [myid:1] - WARN [NIOWorkerThread-7:ZooKeeperServer@1411] - Connection r
浏览 16提问于2021-12-07得票数 3
1回答
我试着用KafkaTool连接卡夫卡。我得到了一个错误:连接到集群的错误。创建新KafkaAdminClient失败
卡夫卡和动物园管理员在码头主持。我运行下一个命令
docker network create kafka
docker run --network=kafka -d --name zookeeper -e ZOOKEEPER_CLIENT_PORT=2181 confluentinc/cp-zookeeper:latest
docker run --network=kafka -d -p 9092:9092 --name kafka -e KAFKA_ZOOK
浏览 0提问于2019-09-23得票数 3
回答已采纳
1回答
我是卡夫卡的新手，我正在尝试创建一个演示卡夫卡服务器并使用它。
我已经创建了动物园管理员和卡夫卡容器使用一个码头-合成文件，他们是启动和运行良好。
如果我将docker exec放入Kafka容器并运行：
kafka-topics --create --zookeeper zookeeper-1 --replication-factor 1 --partitions 1 --topic demo-topic
主题已成功创建..。但是我想把Kafka broker旋转起来，然后以编程的方式创建主题，而不需要用户交互(最终将用于管道)。
我试过两种不同的卡夫卡图像(另一种是合流/cp).我还尝试在
浏览 2提问于2021-09-30得票数 0
回答已采纳
2回答
我试图在我的窗户上安装卡夫卡(8)，这不是工作。
我下载kafka并在c上解压缩它：\kafka之后，我更改了server.properties和zookeeper.properties。
我在那些文件中设置了日志路径。
我甚至尝试下载一个除了卡夫卡安装外的图恩动物园，但动物园管理员运行和卡夫卡没有。
当我试图运行此命令时，会遇到以下错误：
bin\windows\zookeeper-server-start.bat .config\zookeeper.properties
这就是结果：
Classpath is empty. Please build the project first e.
浏览 0提问于2018-01-22得票数 1
回答已采纳
我有单独的动物园管理员图表。我还有单独的卡夫卡图表。卡夫卡图的requirements.yaml和条件zookeeper.enabled中存在着对动物园图的依赖关系。默认情况下卡夫卡图的values.yaml格式
zookeeper:
enabled: true
也就是说，卡夫卡图在构建时包括卡夫卡图和动物园管理员图，在运行时，动物园管理员将按照上述条件进行部署。
现在我想要一些新的雨伞图，让我们称之为TLC图表。在需求中，我把依赖于动物园管理员图表以及卡夫卡图表。另外，我在下面的values.yaml中定义了TLC
kafka:
zookeeper:
enabled: fal
浏览 2提问于2020-10-15得票数 0
回答已采纳
我们有卡夫卡集群，集群包括7卡夫卡经纪人，
版本详细信息：
Kafka machines are installed on rhel version 7.2
Kafka version is 0.1x
Zookeeper version: 3.4.10
schema-registry version: 4.0.0
每台Kafka代理机器包括以下服务
Kafka broker
Zookeeper server
Schema registry
现在我们要从当前的Kafka集群中删除2 Kafka代理机器(我们要删除的卡夫卡机器是- 06/07 ( Kafka版本- 0.1X，)
因此，集群最终应
浏览 2提问于2020-08-19得票数 1
回答已采纳
我们使用的是之前版本的Kafka(0.8.X)，其中所有偏移量细节都存储在ZooKeeper中。现在我们转向了卡夫卡(0.10.X)的新版本，所有的主题偏移细节都存储在Kafka本身中。我们必须将所有的主题偏移细节转移到ZooKeeper，以获取生产中现有的应用程序。卡夫卡安装在Windows机器上。我们不能从窗口运行kafka-消费群。请建议如何将提交的偏移量从ZooKeeper迁移到Kafka。
浏览 0提问于2018-02-08得票数 0
我是卡夫卡的初学者
1/我下载了Kafka的1.0.0版
2/ i更改了位server.properties和zookeeper.properties中的数据目录位置属性
\config\server.properties \config\zookeeper.properties
3/当我试图启动动物园管理员和卡夫卡服务器时，我有一个错误“Files是意外的"
D:\kafka-1.0.0-src\kafka-1.0.0-src\bin\windows>zookeeper-server-start.bat ....\config\zookeeper.properties File
浏览 1提问于2017-11-11得票数 0
我想同时使用confluent/kafka和confluent/zookeeper，并在一个Ubuntu服务器上运行它们。
我使用以下配置：
docker run -e ZOOKEEPER_CLIENT_PORT=2181 --name zookeeper confluent/zookeeper
docker run --name kafka -e KAFKA_ADVERTISED_HOST_NAME=kafka -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 -e KAFKA_CREATE_TOPICS=testtopic:1:1 confluent/ka
浏览 6提问于2019-06-07得票数 8
我知道我们可以执行以下命令：
kubectl get pods -l app==<kafka>获得卡夫卡标签的吊舱
kubectl get pods -l app!=<kafka>获得没有卡夫卡标签的豆荚
kubectl get pods -l app=kafka,env=staging获得卡夫卡和分期标签的吊舱。
但是如果我想列出所有有kafka或zookeeper标签的豆荚，那又如何呢？有点像-l app==kafka||zookeeper。
-l kubectl的选择是否可能.？
浏览 0提问于2019-07-26得票数 0
回答已采纳
1回答
我正试图在我的中运行VirtualBox。我首先通过以下方式运行动物园管理员服务器：
docker run -d -p 2181:2181 --name zookeeper jplock/zookeeper
之后，我运行kafka，它链接到那个动物园管理员服务器：
docker run -d --name kafka --link zookeeper:zookeeper ches/kafka
当我检查“码头ps -a"，只有动物园管理员在运行，卡夫卡不是(卡夫卡的地位总是”退出“。
但是，当我在VM (本地机器)之外执行这些操作时，一切都正常工作。我在这里错过了什么？
更新
浏览 0提问于2018-02-14得票数 0
回答已采纳
我正在一台UUUNT14.04 LTS机器上运行wurstmeister/kafka。卡夫卡集装箱运行良好。但是，我无法将我的微服务连接到这个容器。
Kafka码头-Compose.yml：
version: '2'
services:
zookeeper:
image: user1/zookeeper:3.4.9
ports:
- "2181:2181"
kafka:
image: my-kafka
ports:
- "9092:9092"
hostname: kafka-
浏览 1提问于2016-10-30得票数 6
回答已采纳
在启动汇合平台时，我收到以下错误：
$ ./confluent start
Starting zookeeper
|Zookeeper failed to start
zookeeper is [DOWN]
Cannot start Kafka, Zookeeper is not running. Check your deployment
我的动物园管理员在2181港口，卡夫卡在9092港。
浏览 2提问于2017-10-31得票数 3
我使用的是卡夫卡0.10，没有动物园管理员。我想要卡夫卡主题清单。这个命令不起作用，因为我们没有使用zookeeper：bin/kafka-topics.sh --list --zookeeper localhost:2181。没有动物园管理员，我怎么能得到同样的输出？
浏览 36提问于2017-06-07得票数 102
回答已采纳
我听说Kafka将在即将到来的版本中删除Zookeeper。
到目前为止，Kafka使用Zookeeper处理元数据，选择控制器，以及协调代理和集群拓扑。
我很好奇Kafka将如何处理没有zookeeper的zookeeper角色。
我想知道没有动物园管理员的卡夫卡内部的逻辑。
浏览 19提问于2019-10-20得票数 2
回答已采纳
我有3份文件。一个启动卡夫卡，另两个是消费者和生产者。添加了external_links在另一个码头-组成文件卡夫卡，但仍然无法从内部容器访问卡夫卡。从容器外部，我可以通过localhost:9092访问，但是内部的docker容器呢？
# docker-compose1.yml
version: "3.6"
services:
zookeeper:
image: 'docker.io/bitnami/zookeeper:3.7'
container_name: zookeeper
ports:
- '2181:2
浏览 12提问于2022-04-05得票数 0
回答已采纳
卡夫卡主题语法
kafka-topics.sh --zookeeper zookeeper:2181 --describe --topics-with-overrides
我们得到：
Topic: __consumer_offsets PartitionCount: 50 ReplicationFactor: 3 Configs: compression.type=producer,cleanup.policy=compact,min.insync.replicas=3,segment.bytes=104857600,retention.ms=7200000
我们
浏览 1提问于2021-09-09得票数 0
回答已采纳
1回答
我做到了
docker-compose up
因为卡夫卡聚集在我的本地。
每当我想要制作主题时，检索我拥有的主题或搜索存储在我使用的主题中的数据。
docker run --net=host --rm confluentinc/cp-kafka:latest kafka-topics --describe --topic bar --zookeeper localhost:32181
这是在官方的kafka集群部署站点上。
不过，我真的很想在我当地的仓库里使用卡夫卡，而不是卡夫卡码头的形象。
kafka-topics --describe --topic bar --zookeeper loc
浏览 9提问于2020-01-06得票数 1
回答已采纳
我们正在建立一个新的卡夫卡项目，使用0.8.2.1，并希望将消费者补偿专用于卡夫卡。因此，我们已经在消费者配置中设置了offsets.storage=kafka和dual.commit.enabled=false。然而，当我们创建我们的使用者连接器时，它仍然希望连接到ZooKeeper：
kafka.consumer.Consumer.createJavaConsumerConnector(config);
// fails with:
// Caused by: java.lang.IllegalArgumentException: requirement failed:
//
浏览 0提问于2015-06-08得票数 0
回答已采纳
我们有卡夫卡汇合集群，集群包括3卡夫卡经纪人，
版本详细信息：
Kafka machines are installed on rhel version 7.2
Kafka confluent version is 0.1x
Zookeeper version: 3.4.10
schema-registry version: 4.0.0
每台Kafka代理机器包括以下服务
Kafka broker
Zookeeper server
Schema registry
现在，我们希望向当前的Kafka集群中添加一个额外的新的3 Kafka代理机器(附加的Kafka机器是- kafka04/05/0
浏览 7提问于2020-08-05得票数 2
回答已采纳
我对卡夫卡和动物园管理员都很陌生。我试图运行3个动物园管理员节点和3个卡夫卡经纪人与码头组成的规模的功能。但是无论如何，动物园管理员的实例不会同步(我猜)，代理将在不同的集群中结束。有时是2-1，有时是1-1。无论哪种方式，它们都不会注意到对方，因为当我尝试创建一个具有3个分区和3个副本的主题时，它会给我一个错误，说明可用代理的数量小于复制因子。当我不缩放动物园管理员时，情况就不是这样了，只有docker-compose up --scale kafka=3的卡夫卡。然后，我可以通过kafka-cluster.sh看到所有代理都在同一个集群中。
这是我的船坞-Compose.yml
versi
浏览 6提问于2022-01-08得票数 0
1回答
在Kafka-经理github 一书中写道：
最小配置是用于kafka管理器状态的动物园管理员主机。这可以在conf目录中的application.conf文件中找到。相同的文件将打包在发行版zip文件中；您可以在解压缩所需服务器上的文件后修改设置。
kafka-manager.zkhosts="my.zookeeper.host.com:2181“可以通过逗号分隔多个动物园管理员主机，如下所示：
kafka-manager.zkhosts="my.zookeeper.host.com:2181，other.zookeeper.host.com:2181“或者，如果不想硬编码
浏览 5提问于2020-01-13得票数 0
回答已采纳
我想用两个卡夫卡实例来篡改卡夫卡集群。
运行动物园管理员
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
卡夫卡
docker run -it --name kafka -p 9092:9092 -e ADVERTISED_HOST_NAME=$(hostname -f) --link zookeeper:zookeeper debezium/kafka
运行一个动物园管理员和一个kafka是成功的，但添加第二个kafka容器如下所示
docker run -it
浏览 4提问于2019-09-24得票数 0
回答已采纳
1回答
我正在使用wurstmeister卡夫卡和动物园管理员在我的本地码头图像，以测试SASL和ACL在卡夫卡。
我的船坞-合成人是-
version: '3'
services:
zookeeper:
image: wurstmeister/zookeeper
hostname: zookeeper
container_name: zookeeper
volumes:
- ./zookeeper/zookeeper.sasl.jaas.config:/etc/kafka/zookeeper_server_jaas.conf
-
浏览 3提问于2021-05-29得票数 0
我在亚马逊的EC2和ubuntu上运行卡夫卡。首先，我试图运行动物园管理员服务器并创建一个测试主题。最终的目的是将火花与卡夫卡结合起来进行情感分析。
当我试图启动动物园管理员服务器时，我会收到以下警告，并且进程似乎没有结束，也就是说，在输入以下命令后，我没有看到shell提示符:bin/ zookeeper start.shconfig/zookeeper.properties。
警告没有配置或配置中定义的仲裁，运行在独立模式(org.apache.zookeeper.server.quorum.QuorumPeerMain)中
谢谢您在这方面的任何帮助。
浏览 4提问于2015-06-02得票数 3
回答已采纳
1回答
我已经建立了一个简单的液滴数字海洋，并运行一个单一的卡夫卡和动物园管理员节点，这是启动使用一个码头-合成文件。
我遇到了一个问题，消费或生产卡夫卡经纪人以外的数字海洋液滴。这就是我的船坞组合的样子，
version: '3.4'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
volumes:
- /root/
浏览 1提问于2018-06-06得票数 1
回答已采纳
1回答
我有10个节点，卡夫卡集群，.both，卡夫卡代理和动物园管理员运行在每个节点上。最近，我们增加了3个新节点8 ,9和10，昨天2个节点下降了(2和4)。我有一个有60个分区和3个复制的主题。在卡夫卡经理中，Brokers Skewed %显示为50，Brokers Leader Skewed %显示为70。我已经从UI手动重新分配了分区，Brokers Skewed %现在是0，但是它没有改变Brokers Leader Skewed %。我还运行了命令：
$ kafka-preferred-replica-election.sh --zookeeper localhost:2181 --
浏览 2提问于2020-10-29得票数 4
回答已采纳
2回答
我有两台对接机，我想在码头群中创建一个卡夫卡集群。我的docker-compose.yml看起来是这样的：
version: '3.2'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka:latest
ports:
- "9092:9092"
- "29092:29092"
environm
浏览 1提问于2020-02-18得票数 1
1回答
我有一个名为kafka-zookeeper的任务定义，它有一个Apache代理和一个动物园管理员节点。这些容器需要彼此沟通(这很容易)，也需要与卡夫卡和其他卡夫卡动物园管理员任务中的动物饲养员容器沟通，这就是我不知道该怎么做的。
基本上，我需要这个：
------------------------
___________________ | ___________________ | ___________________
| Task1 | | | Task2 | | | Task2
浏览 0提问于2020-04-13得票数 0
回答已采纳
我正在使用下面的命令docker run -it -p 2181:2181 --name zookeeper zookeeper运行单节点动物园管理员码头映像。为了运行卡夫卡码头图像，我需要共享作为ENV变量的动物园码头图像的IP地址，并更新卡夫卡server.properties文件。
通过码头检查，可以获取动物园管理员图像的IP地址，并在卡夫卡的docker run中传递。
但是有什么方法可以在码头集装箱之间自动检测和共享IP地址吗？
我可以看到一些使用链接的例子，但在最新的docker文档中，这似乎是不可取的。
感谢任何建议/帮助
谢谢
浏览 0提问于2018-03-19得票数 1
1回答
我是卡夫卡的新手，今天我安装了卡夫卡，并试图用下面的命令启动动物园管理员和卡夫卡服务器。bin/动物园管理员-server-start.sh config/zookeeper.properties
但我得到了这个错误。(org.apache.zookeeper.server.ZooKeeperServer) 2022-12-01 10:43:14,624个信息拒绝客户端/xxx.xxx.x.x:39796的会话请求，就像它看到zxid 0x1600000086我们的最后一个zxid是0x43客户端必须尝试另一个服务器(org.apache.zookeeper.server.ZooKeeperS
浏览 14提问于2022-12-01得票数 0
1回答
我正在使用运行一台Dev机器，并在Kubernetes上设置一个本地的Kafka，用于开发库伯内特斯(从码头迁移到学习和练习坐姿)，一切都很好，但我现在正试图将卡夫卡和动物园管理员的卷映射到主机，但我只能查看卡夫卡的卷。对于动物园管理员，我配置并将数据和日志路径映射到卷上，但是内部目录并没有暴露在主机上(这在kafka映射中会发生)，它只显示数据和日志文件夹，而在主机上实际上不存在任何内容，因此重新启动动物园管理员重置状态。
我想知道在使用种类和映射来自不同荚的多个目录时是否有限制或不同的方法，我缺少什么？为什么只有卡夫卡卷才能成功地保存在主机上。
关于如何在文件夹下运行它的自述文件的完整设置
浏览 2提问于2022-01-09得票数 0
回答已采纳
很长一段时间以来，卡夫卡一直试图摆脱Zookeeper。Kafka的最新版本不推荐使用Zookeeper吗？还是Kafka集群仍然需要？
浏览 20提问于2019-12-23得票数 2
回答已采纳
我正在开发一个基于java的应用程序，它可以生成/消费kafka消息。在我的公寓里：
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.9.2</artifactId>
<version>0.8.2.2</version>
</dependency>
我还使用了一个maven执行插件。在eclipse中，它似乎没有调用执行插件，程序构建和运行良好。在
浏览 3提问于2015-12-17得票数 1
回答已采纳
2回答
从卡夫卡的最新消费者版本开始，消费者并不依赖于ZooKeeper。但是"“说Kafka需要Zookeeper，所以启动zookeeper服务器。为什么会这样呢？一旦创建了一个主题，即使我终止了Zookeeper，它也能正常工作。那么Zookeeper的目的仅仅是创建一个主题？如果是这样，为什么不移动创建主题也独立于zookeeper
浏览 14提问于2018-08-05得票数 0
我用的是Kafka0.8.1。我需要在实例化生产者时设置zookeeper.connect属性。我的财产设置如下：
Properties props = new Properties();
props.put("zookeeper.connect","zookeeper2:2181,zookeeper3:2181,zookeeper1:2181/kafka");
但是，卡夫卡一直抱怨说：
main utils.Logging$class(83)：属性zookeeper.connect无效
我在这里看过了：，我还是不明白"zookeeper.co
浏览 4提问于2015-05-01得票数 1
回答已采纳
$ kafka-topics --zookeeper localhost:2181 --list | grep my-topic
my-topic
$ kafka-topics --zookeeper localhost:2181 --delete --topic my-topic
Topic my-topic is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
$ kafka-topics --zookeeper localhost:2181 --l
浏览 1提问于2018-06-05得票数 0
回答已采纳
我试图使用状态集在gke中的集群中部署zookeeper和Kafka服务器，但是Kafka和Zoo门将之间的通信失败了，日志中出现了错误消息。我想知道什么是最简单的方式设置卡夫卡在库伯奈特。
我尝试了以下的配置，我看到卡夫卡未能与动物园管理员沟通，但我不知道为什么？我知道，我可能需要一个无头服务，因为沟通是由卡夫卡和动物园管理员自己处理。
动物园管理员
apiVersion: v1
kind: Service
metadata:
name: zookeeper
spec:
type: LoadBalancer
selector:
app: zookeeper
ports
浏览 0提问于2019-05-22得票数 1
我想使用chroot在动物园管理员卡夫卡的数据。因此，我在server.properties中设置了以下配置
zookeeper.connect=10.114.0.2:2181/kafka,10.114.0.3:2181/kafka,10.114.0.4:2181/kafka
但这是行不通的，我在动物园管理员身上看到了错误的道路：
我如何使用chroot为卡夫卡保存所有卡夫卡数据在/kafka中的动物园管理员？
P.S.：我的卡夫卡版本是3.1.0
浏览 3提问于2022-04-17得票数 0
我在玩卡夫卡，并使用我自己的本地单实例动物园管理员+卡夫卡，并遇到了这个错误，我似乎不知道如何解决。
我为每个启动了一个简单的服务器
$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-server-start.sh config/server.properties
然后，利用 (通过Homebrew安装)，我启动了一个生产者，它将只回显我在控制台中输入的消息
$ kafkacat -P -b localhost:9092 -t TestTopic -T
test1
test1
但是，当我尝试使用这些消
浏览 4提问于2016-02-03得票数 6
2回答
我正在尝试创建一个基于移动事件的分析仪表板。我希望将所有组件对接到docker中的容器中，并将其部署到localhost中，并创建一个分析仪表板。
太阳鸟遥测
卡夫卡
德鲁伊
超集
我所做的
Druid
我执行命令docker build -t apache/incubator-druid:tag -f distribution/docker/Dockerfile .
我执行命令docker-compose -f distribution/docker/docker-compose.yml up
执行完所有操作后，打开并看到德鲁伊正在运行
需要3.5
浏览 1提问于2019-12-17得票数 1
回答已采纳
卡夫卡有个动物园管理员。可以在生产中使用吗？
bin/zookeeper-server-start.sh
我想和卡夫卡一起使用SASL。然而，我无法找到一个方法来折磨它的官方动物园管理员。我确实和卡夫卡动物园管理员合作过。因此，我想知道是否可以在生产环境上使用卡夫卡中的动物园管理员。
浏览 2提问于2018-03-12得票数 2
回答已采纳
我们有卡夫卡版本- 0.1
从卡夫卡的描述，我们可以验证segment.bytes，retention.ms，retention.bytes
kafka-topics.sh --zookeeper zookeeper01:2181 --describe|grep my_first_car
Topic:my_first_car PartitionCount:100 ReplicationFactor:3 Configs:segment.bytes=344778,retention.ms=1780000,retention.bytes=271641765
浏览 2提问于2022-03-07得票数 0
回答已采纳
那么设置在哪里。2编写文件，很快就会变成4。所有的东西都不能生活在同一个撰写文件中，因为它是在项目之间传播的。所以，如果我把一个基本的ngnix服务器放到我的kafka对接器中，我就可以把我的节点应用程序连接到它上，这让我的头脑发火了。但我不能和卡夫卡联系..。如果我在码头外面运行我的节点应用程序，我就能连接到卡夫卡.不知道为什么我不能和卡夫卡联系。
# Micro Services that connect to kafka
version: '3.5'
services:
grouping:
build:
dockerfile: grouping.d
浏览 0提问于2018-04-27得票数 3
我正在使用卡夫卡并面临一个问题。
卡夫卡似乎不使用迷你车在当地工作。我得到了这个erorr: org.apache.kafka.common.errors.InvalidReplicationFactorException:复制因子:1大于可用代理: 0。
Kafka配置：
apiVersion: apps/v1
kind: Deployment
metadata:
name: kafka-depl
spec:
replicas: 1
selector:
matchLabels:
app: kafka
template:
浏览 7提问于2022-04-29得票数 0
我是Apache 的新手，在Windows 7上运行卡夫卡。卡夫卡发布者bat文件不支持动物园管理员选项。我正在使用broker-list选项，这需要代理IP和port.But Linux支持Zookeeper选项。请帮助如何在Windows publisher bat上使用选项。
Windows命令
kafka-console-producer.bat **--broker-list** localhost:9092 --topic test
Linux命令
kafka-console-producer.sh **--zookeeper** localhost:2181 --topic te
浏览 0提问于2015-12-26得票数 1
我已经通过以下命令设置了retention.ms=3600000，但1小时后磁盘上仍然有大量数据。由于卡夫卡的大量数据，我的磁盘已经满了。
./bin/kafka-topics.sh --zookeeper zookeeper:2181 --alter --topic topic_1 --config retention.ms=3600000
描述命令
./bin/kafka-topics.sh --zookeeper zookeeper:2181 --describe --topics-with-overrides
Topic:__consumer_offsets P
浏览 0提问于2018-11-15得票数 1
回答已采纳
4回答
我使用macOS M1 Big 11.2.3，但我的卡夫卡不能运行良好，也不能创建/列出主题。我不知道是不是因为操作系统，但是kafka的日志是这样的：
这是我的船坞组合：
services:
zookeeper:
image: wurstmeister/zookeeper
container_name: zookeeper
hostname: zookeeper
ports:
- 2181:2181
environment:
ZOO_MY_ID: 1
networks:
- kafka_net
k
浏览 18提问于2021-04-20得票数 2
2回答
我试图使用由Bitnami，包装的卡夫卡出口商，以及卡夫卡，的Bitnami图像。我正在尝试运行以下docker-compose.yml
version: '2'
networks:
app-tier:
driver: bridge
services:
zookeeper:
image: 'bitnami/zookeeper:latest'
environment:
- 'ALLOW_ANONYMOUS_LOGIN=yes'
networks:
- app-tier
kafk
浏览 34提问于2022-01-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
