我有个环境问题。我想用zookeeper和kafka集群来解决我的问题。
我的zookeeper版本是3.4.12,kafka版本是2.12-2.1.0
我还更改了zookeeper中的zoo.cfg。
dataDir=D:/WEBSOCKET/zookeeper-3.4.12/data
以及Kafka中的server.properties。
log.dirs=D:/WEBSOCKET/kafka_2.12-2.1.0/logs
我看了所有的教程,做它完全一样的方式。还有乌斯金·Kafka开放Zookeeper。
这是我的命令:
1) 打开zookeeper(zkserver.cmd)
2) 在Kafka
.\bin\windows\kafka-server-start.bat.\config\server.properties
3) 创建主题
.\bin\windows\kafka-topics.bat--创建--缩放器localhost:2181 --replication-factor 1--分区1--主题hello
4) 创建生产者
.\bin\windows\kafka-console-producer.bat—引导服务器localhost:2181 --topic 你好
5) 创建使用者
.\bin\windows\kafka-console-consumer.bat—引导服务器localhost:2181 --topic 你好
当我进入第五步时,我总是失败。Zookeeper会给我很多控制台,比如:
WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:55192
以及
2019-01-08 17:05:24,822 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50874 (no session established for client)
2019-01-08 17:05:25,783 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:56089
我不知道怎么修。我搜索了两天。。。
当我用第二步打开我的Kafka时,我的Zookeeper有时没有任何React,或者给我看这个:
[ProcessThread(sid:0 cport:2181)::PrepRequestProcessor@596] - Got user-level KeeperException when processing sessionid:0x1000058f8960000 type:multi cxid:0x36 zxid:0x69 txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election
我也谷歌这个,但没有帮助。
我以前在kfaka中设置过:advised.host.name=localhost listeners=plaintext://127.0.0.1:9092
我的主机设置了127.0.0.1 localhost
请帮助我创建本地服务器,我想编码我的项目。。
谢谢你读了全部。
1条答案
按热度按时间qncylg1j1#
生产者和消费者需要使用端口9092(Kafka)
您看到zookeeper日志和错误,因为您正在尝试使用
bootstrap-server
或者broker-list
端口2181(zookeeper)再次查看快速入门指南