debezium/zookeeper端口2181已关闭
Debezium是一个开源的分布式数据变更捕获平台，它可以将现有的数据库作为事件流提供给应用程序，以便实时监测和分析数据库中的数据变化。
ZooKeeper是Apache软件基金会的一个开源项目，它是一个分布式的协调服务，用于管理和协调分布式应用程序的配置信息、命名服务、分布式锁等。
端口2181是ZooKeeper默认的客户端通信端口，用于与ZooKeeper集群进行交互。
如果debezium/zookeeper端口2181已关闭，可能会导致以下问题：
- 无法与ZooKeeper集群建立连接：ZooKeeper客户端无法通过2181端口与ZooKeeper集群进行通信，这将影响到应用程序对ZooKeeper的配置信息、命名服务等的访问。
为了解决这个问题，可以尝试以下方法：
- 检查ZooKeeper集群状态：确认ZooKeeper集群是否正常运行，并确保2181端口处于开放状态。
- 检查防火墙设置：如果使用了防火墙，确保2181端口在防火墙规则中被允许通过。
- 检查网络连接：确保网络连接正常，尝试通过telnet命令检查是否能够访问到2181端口，例如：telnet <ZooKeeper IP> 2181。
- 检查配置文件：检查debezium或应用程序的配置文件，确保指定了正确的ZooKeeper地址和端口。
- 检查ZooKeeper日志：查看ZooKeeper的日志文件，检查是否有相关的错误或异常信息。
对于云计算领域来说，Debezium和ZooKeeper在以下方面具有重要作用：
- 实时数据变更捕获和分析：通过Debezium，可以将数据库中的数据变化以事件流的形式提供给应用程序，实现实时的数据监测和分析。
- 分布式应用程序协调：ZooKeeper作为一个分布式的协调服务，可以用于分布式应用程序的配置信息管理、命名服务、分布式锁等，保证分布式应用程序的一致性和可靠性。
- 增强系统可伸缩性和弹性：使用Debezium和ZooKeeper可以实现分布式系统的水平扩展和故障恢复，提高系统的可伸缩性和弹性。
腾讯云提供了一系列与Debezium和ZooKeeper相关的产品和服务，可以帮助用户快速搭建和管理分布式数据变更捕获和协调服务，例如：
- 腾讯云消息队列 CMQ：CMQ是一种高可用、高可靠、全托管的消息队列服务，可用于实现实时数据的异步传输和解耦，提供了与Debezium类似的功能。 产品介绍链接：https://cloud.tencent.com/product/cmq
- 腾讯云分布式应用服务 TDSW：TDSW提供了分布式应用的配置中心和服务注册与发现功能，类似于ZooKeeper，可用于分布式应用程序的配置管理和服务协调。 产品介绍链接：https://cloud.tencent.com/product/tdsw
请注意，以上推荐的腾讯云产品仅供参考，并不代表是必选方案，用户可以根据自身需求选择适合的产品和服务。同时，还可以参考其他厂商提供的类似产品。
相关·内容
我正在尝试为mysql数据库连接多个Debezium连接器，我的配置如下。
sudo docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.5 &
sudo docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:1.5 &
sudo docker run -it --name connect -p 8083:8083 -e GROUP
浏览 1提问于2021-06-07得票数 0
2回答
我试着用Debezium和卡夫卡连接，我跟踪，所有连接都很好。然而，问题是，我不能再从码头集装箱以外的卡夫卡。
我使用以下命令启动容器：
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:2.0.0.Beta1
docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:2.0.0.Beta1
docker run -it --rm --
浏览 3提问于2022-08-14得票数 0
回答已采纳
我有一个来自https://hub.docker.com/r/debezium/zookeeper:1.2图像和我的撰写文件的正在运行的Zookeeper实例： version: "3.7"
services:
zookeeper:
image: debezium/zookeeper:1.2
ports:
- "2181:2181"
- "2888:2888"
- "3888:3888"
networks:
common:
volumes:
浏览 91提问于2020-10-12得票数 1
1回答
我的问题是：
version: '2'
services:
zookeeper:
container_name: zookeeper
image: debezium/zookeeper:${DEBEZIUM_VERSION}
ports:
- 2181:2181
- 2888:2888
- 3888:3888
kafka:
container_name: kafka
image: debezium/kafka:${DEBEZIUM_VERSION}
ports:
- 9092:909
浏览 3提问于2021-04-26得票数 0
我正在构建Kafka CDC，但根据文档，它运行许多docker-run命令。
我想把它全部放到一个docker-compose.yml中，但是我在最后一个命令时失败了，我不能转换成
以下是命令
docker run -d --name postgres \
-p 5432:5432 \
-e POSTGRES_USER=start_data_engineer \
-e POSTGRES_PASSWORD=password debezium/postgres:12
docker run -d --name zookeeper
浏览 22提问于2021-12-03得票数 0
我目前对所有这些工具都是新手，请您多多关照。
我正在尝试创建一个数据管道来将MySQL DB的更改推送到Kafka代理。我松散地尝试遵循教程。如果所有的docker容器(直接从debezium repos下载)都位于本地机器中，我就能够让系统运行。
然而，如果我将MySQL，Kafka和Zookeeper dockers放在我的本地网络上的另一台机器上，并尝试连接它，我得到了以下错误：
docker: Error response from daemon: could not get container for zookeeper: No such container: zookeeper.
浏览 7提问于2018-08-09得票数 0
目前，我正在WSL2环境中使用WSL2 12，我希望用debezium和kafka来实现cdc。由于我是第一次这样做，我搜索了所有的教程显示这个过程与码头。
在我的例子中，如果不是关于postgres的话，跟码头没有问题。我不想使用postgres/码头。
我只是想把debezium和kafka连接到我现有的磁盘上的postgres。请建议我的教程或方式，我可以联系。这将是一个巨大的帮助。谢谢。
我做了这两个步骤：
步骤1
docker run -it --rm --name zookeeper_debezium -p 2181:2181 -p 2888:2888 -p 3888:3888
浏览 2提问于2020-07-02得票数 0
我正在尝试为Kafka更改数据捕获设置一个Docker文件环境，我遇到了以下错误：
打开到服务器的套接字连接0.0.0.0/0.0.0.0:2181。不会尝试使用SASL (未知错误)进行身份验证。
发生套接字错误: 0.0.0.0/0.0.0.0:2181:连接被拒绝
我一直在学习本教程，但它直接使用链接选项运行对接器命令，而不是使用docker-compose.yml文件。
我试图将这些转换为：
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka
到下面的docker-
浏览 4提问于2021-02-07得票数 4
回答已采纳
我是卡夫卡的新手，我不知道如何使用"transforms.router.type“来使它与我的Debezium设置一起工作。因此，我对java类进行了特殊的事件转换，并对其进行了预配置，以便将其部署到容器中，如下所示：
curl -X POST -H "Accept:application/json“-H”内容-Type:application/json“localhost:8083/连接器/ -d
{
"name": "task-connector",
"config": {
"connector.cla
浏览 6提问于2020-08-07得票数 1
回答已采纳
我想知道这些命令之间的区别。 -- With bootstrap server
kafka-topics \
--bootstrap-server b-1.bhuvi-cluster-secure.jj9mhr.c3.kafka.ap-south-1.amazonaws.com:9098,b-2.bhuvi-cluster-secure.jj9mhr.c3.kafka.ap-south-1.amazonaws.com:9098 \
--delete \
--topic debezium-my-topic \
--command-config /etc/kafka/client.prope
浏览 24提问于2021-08-26得票数 0
回答已采纳
我想用码头运行一个动物园管理员的形象。指令命令是
docker run -d -p 2181:2181 -p 2888:2888 -p 3888:3888 --name zookeeper confluent/zookeeper
我不清楚-p选项，在这个动物园管理员的例子中，这三个"-p“选项意味着什么？以及为什么在一个-p选项中有两个相同的端口值。我希望是2181:localhost，而不是2181:2181。
浏览 3提问于2016-12-08得票数 1
回答已采纳
我使用docker运行kafka，在卷上设置存储数据。我设置了一些源连接器，主题是用cleanup.policy delete自动创建的。通过使用kafka经理，我将策略更改为compact。
问题：
在停止/启动停靠-组合主题出现后，但是cleanup.policy被恢复回delete。
问题：
重启后如何持久化主题配置？
附加信息
我命令重新启动卡夫卡码头工人：
rm /kafka/data/1/meta.properties; docker-compose down && docker-compose up -d --no-recreate
Docker-compose.
浏览 0提问于2020-10-21得票数 1
回答已采纳
1回答
我遵循了以下步骤：
# Run postgres instance
docker run --name postgres -p 5000:5432 debezium/postgres
# Run zookeeper instance
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
# Run kafka instance
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper de
浏览 6提问于2019-08-02得票数 0
比方说，我将获得多个MySQL实例，并且必须流式传输实时数据。为此，我使用下面列出的命令在Docker Container上启动了一些服务，这些命令将我连接到示例库存数据库，并且当我在MySQL命令行客户端中执行任何DML命令时，都能够监控这些数据的变化。
但是，连接到实际的MySQL数据库并在观察器窗口中传输相同的内容所需的更改或等效命令是什么呢？
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.1
docker run -it --rm --n
浏览 2提问于2020-05-27得票数 1
我有一个码头组成的群与动物园管理员服务启动良好，但卡夫卡服务不能启动。
它一直使用默认的KAFKA_ADVERTISED_LISTENERS属性：
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using ZOOKEEPER_CONNECT=zookeeper:2181
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.0.83.239:9092
当然，它也找不到映射中指定的侦听器：
debezium_kaf
浏览 0提问于2020-10-20得票数 1
我不能使用以下命令添加MySQL连接器： curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{ "name": "useraccount-connector", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector
浏览 56提问于2020-10-15得票数 2
2回答
我是kubernetes的新手，我正在尝试将kafka与debezium和mysql集成。我成功地在minikube上部署了kafka和mysql，一旦我在minikube上部署了debezium yml，它就被挂起了，完全没有响应，然后我重新启动minikube，在运行完所有的pod minikube之后再次被挂起。下面是我的代码：
zookeeper服务
apiVersion: v1
kind: Service
metadata:
name: zoo1
labels:
app: zookeeper-1
spec:
ports:
- name: client
浏览 2提问于2018-12-08得票数 0
我正在使用docker通过以下命令运行zookeeper和kafka实例 docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper -e ADVERTISED_HOST_NAME=localhost -e HOST_NAME=localhost debezium/kafka ADVERTISED_HOST_NAME
浏览 49提问于2020-07-26得票数 1
2回答
我在docker中运行Kafka，我有一个.NET应用程序，我想使用它来使用消息。我在没有运气的情况下遵循了下面的教程：
在我的使用者应用程序中，如果我试图直接连接到容器ip，我会得到以下错误：
172.21.0.3:9092/bootstrap: Connect to ipv4#172.21.0.3:9092 failed: Unknown error (after 21502ms in state CONNECT)
Error: 1/1 brokers are down %3|1620652406.633|FAIL|rdkafka#consumer-1| [thrd:172.21.0
浏览 18提问于2021-05-10得票数 1
回答已采纳
1回答
对接MySQL数据库
、、、、
我是新来的debezium，正在尝试将我的kafka连接器连接到我在本地WAMP服务器上已经存在的MySQL数据库。
根据教程文档，我开始了动物园管理员和kafka，然后我启动了kafka连接器。在我的邮递员中，我向我的kafka连接器发送了以下JSON，但是我一直收到一个糟糕的请求响应。
启动Zookepper
docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:0.7
启动卡夫卡
docker run -it --rm --name kafka -p 9
浏览 0提问于2018-06-21得票数 0
对于我的Debezium连接器，我有以下docker-compose.yml配置： version: '3.1'
services:
db:
image: mysql
network_mode: host
environment:
MYSQL_ROOT_PASSWORD: 123456
volumes:
- ./mysql.cnf:/etc/mysql/conf.d/mysql.cnf
ports:
- 3306:3306
浏览 85提问于2019-03-08得票数 0
2回答
嗨，我是hbase和hadoop.I的新手。我已经正确地设置了它们，但从同一台机器上检查它们，当尝试从java客户端远程连接时，它正在工作fine.Now，这个异常即将到来。我真的需要帮助，请指导我这一点。例外情况如下：
/04/17 17:41:35 INFO zookeeper.ZooKeeper: Client environment:user.name=xyz
12/04/17 17:41:35 INFO zookeeper.ZooKeeper: Client environment:user.home=/home/xyz
12/04/17 17:41:35 INFO zookeepe
浏览 6提问于2012-04-18得票数 1
回答已采纳
我想用两个卡夫卡实例来篡改卡夫卡集群。
运行动物园管理员
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
回答已采纳
我试图使用自定义有效负载列(after)和附加的jsonb列(before)运行一个独立的Debezium和一个发送框SMT，但是任务是抛出错误：
debezium | 2019-05-21 23:07:50,267 ERROR || WorkerSourceTask{id=campaigns-outbox-connector-0} Task threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]
debezium |
浏览 12提问于2019-05-21得票数 1
回答已采纳
1回答
我正在使用OpenTSDB的，但在运行该程序时得到了如下所示的错误。有人能帮上忙吗？
运行命令时：
./build/tsdb tsd --port=4242 --staticroot=build/staticroot --cachedir="$tsdtemp"
我得到了这个错误：
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.6.0_20]
at sun.nio.ch.SocketCh
浏览 0提问于2011-12-19得票数 1
回答已采纳
我试图获得一个简单的Debezium堆栈(与Docker一起运行)，但是到Kafka broker的连接失败了。
这是我的简化docker-compose.yml
version: "3"
services:
zookeeper:
image: debezium/zookeeper:1.6
ports:
- "2181:2181"
- "2888:2888"
- "3888:3888"
kafka:
image: debezium/kafka:1.6
li
浏览 30提问于2021-07-30得票数 0
回答已采纳
我使用Apache Kafka和Debezium的连接器服务来查看我的表中的数据更改。另外，我使用的是亚马逊网络服务EC2，其中我有一个包含联邦表的数据库。如果我创建了一个非联邦表，并使用Zookeeper、Kafka和Kafka连接来运行我的docker观察器，我可以从该表中读取数据，但是当我看到一个联邦表时，就不能读取数据。 我试图在连接器的配置中添加一个查询，但这不起作用。 我的命令是： 启动Zookeeper $ docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/z
浏览 20提问于2019-07-02得票数 0
我正在尝试为需要运行多个docker容器的CDC (变更数据捕获)解决方案创建一个docker-compose文件。我的DockerComposeLocal.yml包含以下内容： version: "3"
services:
postgres:
image: debezium/postgres:12
ports:
- "5432:5432"
environment:
- POSTGRES_USER=postgres
- POSTGRES_PASSWORD=123
zookeper:
浏览 16提问于2021-08-16得票数 0
我有一个spring应用程序，它应该连接到kafka。这是我的Docker文件查找spring应用程序的内容：
FROM maven:3-jdk-11 as builder
# create app folder for sources
RUN mkdir -p /build
WORKDIR /build
COPY pom.xml /build
#Download all required dependencies into one layer
RUN mvn -B dependency:resolve dependency:resolve-plugins
#Copy source code
浏览 3提问于2020-06-01得票数 1
我有一个与卡夫卡，动物园管理员和春季引导应用程序的对接-撰写文件。当我运行整个文件时，一切正常。当我在没有spring引导应用程序的情况下运行它时，为了通过intellij调试它，它无法连接到Kafka，并且不能正常工作。
我的船坞-撰写文件：
version: "3.5" services: # Install Zookeeper. zookeeper:
container_name: zookeeper
image: debezium/zookeeper:1.2
networks:
- mynetwork
ports:
浏览 2提问于2021-11-26得票数 0
回答已采纳
我正在尝试为Pulsar设置Zookeeper集群。我正在按照here的说明进行操作，但是我总是失败。 在我的设置中，我有两个节点，它们应该是集群的一部分。由于我需要将bookie部署到相同的节点，因此我执行了 $ PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" bin/pulsar-daemon start zookeeper 启动zookeeper。之后，我尝试使用以下命令初始化集群： bin/pulsar initialize-cluster-metadata \
--cluster pulsar-cluster-1 \
浏览 123提问于2019-09-02得票数 0
当我用这个堆栈设置我的Swarm时:Kafka(多代理)，zookeeper，debezium。Kafka和zookeeper正在工作，可以创建topic、consumer和producer，但debezium显示错误: org.apache.kafka.connect.errors.ConnectException:无法连接和描述Kafka集群。检查worker的代理连接和安全属性。我没有修改任何东西，只是默认配置为docker-stack：
version: '3.6'
services:
zoo:
image: wurstmeister/zookeepe
浏览 23提问于2018-08-03得票数 0
我是第一次接触kafka，正在使用debezium kafka来跟踪我的postgrest表中的变化。下面是我的docker-complse.yml
version: '3.8'
volumes:
shared-workspace:
name: "hadoop-distributed-file-system"
driver: local
services:
postgres:
restart: always
image: debezium/postgres
container_name: postgr
浏览 10提问于2021-08-27得票数 0
我尝试使用对象，并遵循来实现这一点。下面是正在使用的代码：
private final KafkaProducer producer;
private final Serializer serializer;
public KafkaEventPublisher(String zookeeper, Serializer serializer) {
Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, zookeeper);
props.put(Pr
浏览 1提问于2018-03-28得票数 0
我想使用Kafka发布MSSQL事件。
我正在使用码头集装箱：
debezium/动物园饲养员
debezium/kafka
debezium/连接
集装箱的启动方式如下：
docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka
docker run -it --name con
浏览 2提问于2019-06-02得票数 2
回答已采纳
2回答
问题：
如何使用Kafka正确注册SqlServer连接器以连接到独立SqlServer实例？注意:我没有在Docker中运行Server。
错误：
com.microsoft.sqlserver.jdbc.SQLServerException:错误:由：连接到主机的/IP连接127.0.0.1，端口1433失败。错误：“连接拒绝(连接拒绝)。请验证连接属性。确保Server实例在主机上运行，并在端口接受TCP/IP连接。确保到端口的TCP连接不会被防火墙阻塞”。
Troubleshooting:
在Server配置管理器的Server ConfigurationDisabled Firew
浏览 4提问于2020-04-07得票数 1
回答已采纳
我的Dockerfile，用于下载接收器连接器和mysql jdbc驱动程序 FROM debezium/connect
ENV KAFKA_CONNECT_JDBC_DIR=$KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ENV MYSQL_DRIVER_VERSION 5.1.39
ARG KAFKA_JDBC_VERSION=5.5.0
RUN curl -k -SL "https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-${MYSQL_DRIVER
浏览 34提问于2020-07-07得票数 0
回答已采纳
当我运行命令zkCli时，得到了以下输出：
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is enabled
[zk: localhost:2181(CONNECTING) 0] ls /
KeeperErrorCode = ConnectionLoss for /
[zk: localhost:2181(CONNECTING) 1]
我使用自制安装和服务启动动物园管理员，它成功启动！zkServer status如下所示
ZooKeeper JMX enabled by default
Using conf
浏览 3提问于2020-05-22得票数 0
我使用表映射器和缩减程序对大规模问题进行了一些测试。在某个时间点之后，我的减速机开始失效，此时工作完成了80%。从我查看syslog时可以看出，问题是我的一个动物园管理员正在尝试连接到本地主机，而不是仲裁中的其他动物园管理员
奇怪的是，当映射正在进行时，它似乎可以很好地连接到其他节点，它减少了它遇到的问题。以下是系统日志的精选部分，它们可能与弄清楚发生了什么有关
2014-06-27 09:44:01,599 INFO [main] org.apache.zookeeper.ZooKeeper: Initiating client connection, connectString=hdev0
浏览 3提问于2014-06-28得票数 6
1回答
我试着从以下几个方面着手：
/opt/Kafka/kafka_2.10-0.10.0.1/bin/zookeeper-server-start.sh
/opt/Kafka/kafka_2.10-0.10.0.1/config/zookeeper.properties
但我有
错误意外异常，退出异常的(org.apache.zookeeper.server.ZooKeeperServerMain) java.net.BindException:已在使用的地址
我重新启动了电脑，也遇到了同样的问题。
我尝试了netstat -nlp|grep 2181，结果是：
tcp6
浏览 0提问于2018-04-19得票数 1
回答已采纳
我正在尝试连接我的kafka设置与zookeeper容器暴露到一个不同的端口而不是默认端口，但是当我将端口更改为2181时，容器运行正常，但如果我在yml文件中更改端口，我无法运行它，任何指导都将是有帮助的。 version: '3'
services:
zookeeper:
image: wurstmeister/zookeeper
container_name: zookeeper
ports:
- "2182:2181"
kafka:
image: wurstmeister/kafka
container_name:
浏览 35提问于2021-03-24得票数 1
回答已采纳
2回答
卡夫卡集群模式端口配置
、、、
我正在尝试部署一个带有3个动物园管理员和3个kafka节点的对接卡夫卡集群。kafka节点不断停止打印以下错误：
[main-SendThread(zookeeper-1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server zookeeper-1/10.0.0.5:2181. Will not attempt to authenticate using SASL (unknown error)
[main-SendThread(zookeeper-1:2181)] INFO org.
浏览 2提问于2019-03-01得票数 1
回答已采纳
docker-compose文件的图像如下所示。 version: '2'
services:
zookeeper:
image: 'bitnami/zookeeper:3'
ports:
- '2181:2181'
volumes:
- 'zookeeper_data:/bitnami'
environment:
- ALLOW_ANONYMOUS_LOGIN=yes
kafka:
image: 'bitnami/kafka:2&
浏览 138提问于2021-02-27得票数 0
回答已采纳
2回答
对于集群设置有一点困惑：
通过配置myid (1，2，3.)，可以将动物园管理员设置为集群。在文件中，例如，在zoo.cfg文件中有zookeeper2 1:2888:3888，zookeeper2:2889:3889
对于Kafka，在server.properties文件中，它必须为参数zookeeper.connect指定完整的动物园管理员服务器列表，还是仅仅1就足够了？有什么不同吗？即使在创建主题时，我也看到了指定动物园管理员服务器完整列表的实践，例如/opt/kafka/bin/kafka-topics.sh --创建--动物园管理员x.x:2181，x.x:2181，x.x
浏览 1提问于2018-08-21得票数 0
回答已采纳
我正在设置HBase配置new HBaseGraphConfiguration().set("hbase.zookeeper.quorum", ZOOKEPER_QORUM_NODE)
ZOOKEPER_QORUM_NODE = "172.31.17.251:2181,172.31.17.252:2181,172.31.17.253:2181";
不管它抛出一个java.lang.NumberFormatException，错误的部分是
Caused by: java.lang.NumberFormatException: For input string: &
浏览 1提问于2018-06-01得票数 0
回答已采纳
我有一个环境问题。我想用zookeeper和Kafka集群来解决我的问题。 我的zookeeper版本是3.4.12，Kafka是2.12-2.1.0 我还更改了zookeeper中的zoo.cfg。 dataDir=D:/WEBSOCKET/zookeeper-3.4.12/data 还有卡夫卡的server.properties。 log.dirs=D:/WEBSOCKET/kafka_2.12-2.1.0/logs 我看到了所有的教程，并以完全相同的方式完成它。还有usgin open zookeeper。 这是我的命令： 1)打开zookeeper (zkServer.cmd) 2)
浏览 70提问于2019-01-08得票数 0
回答已采纳
按照这两个教程:即和，我能够在完全分布式模式下设置HBase集群。最初，集群似乎运行良好。
HMaster/ Name节点中的“jps”输出
DataNodes/ RegionServers中的jps输出
尽管如此，当我每次尝试执行hbase时，HBase处理器似乎都会因为某些动物园管理员错误而中断。错误粘贴在下面：
2021-03-13 11:52:26,047 ERROR [main] zookeeper.RecoverableZooKeeper: ZooKeeper exists failed a│1951 HRegionServer
fter 4 attempts
浏览 1提问于2021-03-13得票数 0
回答已采纳
下面是yml文件，用于在一个用于kafka和zookeeper的AWS实例中调出docker容器： version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
build: .
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_HOSTNAME: <machines private ip>
浏览 24提问于2019-06-26得票数 0
1回答
我是卡夫卡的新手，我试着用在vps上安装我的第一个集群。但我仍然无法从本地pc (主机外)访问它。
这是我的码头作曲
version: '2'
services:
zookeeper-1:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
ports:
- 22181:21
浏览 42提问于2022-04-13得票数 1
回答已采纳
1回答
我正在我的mac机上运行一个被篡改的卡夫卡(MacOS塞拉利昂(10.12.2))，但失败了。我有DockerforMacVersion17.03.1-ce，构建c6d412e。这些是我用的图像。
我遵循官方中的建议，使用以下命令运行Zookeeper和Kafka。
docker run -d \
--net=host \
--name=zookeeper \
-e ZOOKEEPER_CLIENT_PORT=32181 \
confluentinc/cp-zookeeper:3.2.1
docker run -d \
--net=
浏览 0提问于2017-06-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
