Кафка тема больше не существует после перезагрузки
Я создал тему в своем локальном кластере kafka с 3-мя серверами / брокерами, выполнив следующую команду из моего каталога установки kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic user-activity-tracking-pipeline
Все работало нормально, так как мне удавалось выдавать и потребительские сообщения из моей темы. После перезагрузки компьютера я запустил пакет zookeeper из каталога установки kafka, выполнив в терминале следующее
bin/zookeeper-server-start.sh config/zookeeper.properties
Запустил 3 сервера, принадлежащих кластеру, выполнив в терминале из каталога установки kafka следующее
env JMX_PORT=10001 bin/kafka-server-start.sh config/server1.properties
env JMX_PORT=10002 bin/kafka-server-start.sh config/server2.properties
env JMX_PORT=10003 bin/kafka-server-start.sh config/server3.properties
Теперь, когда я перечисляю доступные темы, запустив следующее в терминале из каталога установки kafka,
bin/kafka-topics.sh --zookeeper localhost:2181 --list
результат пуст!
Вот соответствующие записи конфигурации сервера 1. Значения для сервера 2 и сервера 3 очень похожи
broker.id=1
listeners=PLAINTEXT://:9093
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=/tmp/kafka-logs-broker-1
num.partitions=2
num.recovery.threads.per.data.dir=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
log.cleaner.enable=false
zookeeper.connect=localhost:2181
zookeeper.connection.timeout.ms=6000
После перезапуска я замечаю файлы журналов, поэтому ничего не убиралось
/tmp/kafka-logs-broker-1
/tmp/kafka-logs-broker-2
/tmp/kafka-logs-broker-3
Мне интересно, почему ранее созданная тема«Пользователь-активность по отслеживанию трубопроводов» больше не существует, когда я пытаюсь перечислить это?