У меня проблема с окружающей средой.
Я хочу использовать zookeeper и Kafka для решения моей проблемы.
Моя версия zookeeper - 3.4.12, а Kafka - 2.12-2.1.0
Я также изменяю zoo.cfg в zookeeper.
dataDir=D:/WEBSOCKET/zookeeper-3.4.12/data
и server.properties в кафке.
log.dirs=D:/WEBSOCKET/kafka_2.12-2.1.0/logs
Я вижу все уроки и делаю это точно так же.
А также usgin kafka open zookeeper.
это моя команда:
1) открыть zookeeper (zkServer.cmd)
2) в кафке
. \ Bin \ windows \ kafka-server-start.bat. \ Config \ server.properties
3) создать тему
. \ Bin \ windows \ kafka-themes.bat --create --zookeeper localhost: 2181 - коэффициент репликации 1 - разделы 1 - топический привет
4) создать продюсера
. \ Bin \ windows \ kafka-console -roduction.bat --bootstrap-server localhost: 2181 --topic hello
5) создать потребителя
. \ Bin \ windows \ kafka-console-consumer.bat --bootstrap-server localhost: 2181 --topic hello
когда я попадаю на шаг 5, я всегда терплю неудачу.
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
Я не знаю, как это исправить. Я гуглю два дня ...
когда я открываю свою Кафку с шагом 2, мой зоопарк иногда не получает никакого ответа или показывает мне следующее:
[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
Я тоже гуглю это, но не полезно.
Я установил это в кфака раньше:
advertised.host.name = localhost
слушатели = PLAINTEXT: //127.0.0.1: 9092
мой хозяин установил
127.0.0.1 localhost
, пожалуйста, помогите мне создать локальный сервер, я хочу, чтобы код моего проекта ..
спасибо, что прочитали все.