Следуя инструкциям в уроке 28 курса изучения Apache Kafka для начинающих Удеми , чтобы запустить zookeeper, а затем запустить брокер сервера kafka в Windows 10. Zookeeper отлично работает на порту 2181:
C:\kafka_2.12-2.3.1> zookeeper-server-start.bat config/zookeeper.properties
...
привязка INFO к порту 0.0.0.0/0.0.0.0:2181
Но после добавления файлов bat в путь, запущенный сервер kafka неработа:
C:\kafka_2.12-2.3.1> kafka-server-start.bat config/server.properties
...
ОШИБКА Во время загрузки журналов произошла ошибка в одном из потоков: org.apache.kafka.common.KafkaException: найден каталог C: \ kafka_2.12-2.3.1 \ data \ kafka, 'kafka' не в форме раздел-раздел или раздел-раздел.uniqueId-delete (если помечен для удаления). Каталоги журналов Кафки (и дочерние) должны содержать только данные тем Кафки. (kafka.log.LogManager)
Некоторые записи stdout в zookeeper выглядят информативно:
Допустимое подключение к сокету из /127.0.0.1:49439 (org.apache. zookeeper.server.NIOServerCnxnFactory) [2019-11-03 17: 22: 42,278] INFO Клиент пытается установить новый сеанс по адресу /127.0.0.1:49439 (org.apache.zookeeper.server.ZooKeeperServer) [2019-11-03 17: 22: 42,286] INFO Создание нового файла журнала: log.1 (org.apache.zookeeper.server.persistence.FileTxnLog)
...
INFO Обработанное завершение сеанса для sessionid: 0x1007b0044a40000(org.apache.zookeeper.
В созданной мной папке data есть две созданные мной папки, вторая из которых была заполнена после того, как я попытался запустить брокер kafka:
kafka/ | -- пусто zookeeper/ | - version-2/ | - log.1
Почему возникает эта ошибка и как я могу запустить сервер Kafka в Windows 10?
РЕДАКТИРОВАТЬ:
Содержимое config/server.properties:
num.network.threads = 3
num.io.threads = 8
socket.send.buffer.bytes = 102400
socket.receive.buffer.bytes= 102400
socket.request.max.bytes = 104857600
log.dirs = C: /kafka_2.12-2.3.1/data/
num.partitions =1
num.recovery.threads.per.data.dir = 1
offsets.topic.replication.factor = 1
action.state.log.replication.factor= 1
транзакция.state.log.min.isr = 1
log.retention.hours = 168
log.segment.bytes = 1073741824
log.retention.check.interval.ms = 300000
zookeeper.connect = localhost: 2181
zookeeper.connection.timeout.ms = 6000
group.initial. rebalance.delay.ms = 0