我在本地 kafka 集群中创建了一个主题,其中包含 3 个服务器/代理
通过从我的 kafka 安装目录运行以下命令
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic user-activity-tracking-pipeline
一切都很顺利,因为我能够根据我的主题生成和使用消息。重新启动计算机后,我通过在终端中运行以下命令从 kafka 安装目录启动捆绑的 Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
通过在 kafka 安装目录的终端中执行以下命令,启动属于集群的 3 个服务器
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
我想知道为什么之前创建的主题“用户活动跟踪管道”当我尝试列出它时不再存在?