当前位置: 首页 > 知识库问答 >
问题:

无法在Windows 10上启动Kafka服务器-Kafka的日志目录(和子目录)应仅包含Kafka主题数据

司宏伯
2023-03-14

按照《初学者学习Apache Kafka》第28课中的说明,我的课程将启动zookeeper,然后在Windows 10上启动Kafka服务器代理。Zookeeper在端口2181上运行良好:

C:\kafka_2.12-2.3.1> zookeeper-server-start.bat config/zookeeper.properties

...

信息绑定到端口0.0.0.0/0.0.0.0:2181

但在将bat文件添加到path后,运行kafka服务器不起作用:

C:\kafka_2.12-2.3.1> kafka-server-start.bat config/server.properties

...

错误加载日志时,其中一个线程出错:org。阿帕奇。Kafka。常见的KafkaException:找到目录C:\kafka\u 2.12-2.3.1\data\kafka,“kafka”不是主题分区或主题分区的形式。唯一ID删除(如果标记为删除)。Kafka的日志目录(和子目录)应仅包含Kafka主题数据。(Kafka日志管理器)

zookeeper中的一些stdout日志看起来信息丰富:

接受来自/127.0.0.1:49439的套接字连接(org.apache.zookeeper.server.NIOServerCnxnFactory)[2019-11-03 17:22:42,278]INFO Client尝试在/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)

...

[2019-11-03 17:22:42,987]INFO用于具有setsionid 0x1007b0044a40000(org.apache.zookeeper.server.NIOServerCnxn)的客户端/127.0.0.1:49439的已关闭套接字连接

在我创建的数据文件夹下,有两个我创建的文件夹,第二个是在我尝试运行kafka broker后填充的:

Kafka-空的zookeeper-第二版-日志。1

为什么会发生此错误?如何在Windows 10上启动Kafka服务器?

编辑:

配置/服务器的内容。属性:

网络数量。Thread=3

num.io.threads=8

socket.send.buffer.bytes=102400

插座接收缓冲器字节=102400

插座要求最大字节数=104857600

日志目录=C:/kafka\u 2.12-2.3.1/data/

num.partitions=1

num.recovery.threads.per.data.dir=1

偏移量。话题复制。系数=1

交易状态日志复制。系数=1

交易状态日志最小isr=1

日志保持小时=168

日志段字节=1073741824

log.retention.check.interval.ms=300000

动物园管理员。connect=本地主机:2181

zookeeper.connection.timeout.ms=6000

group.initial.rebalance.delay.ms=0

共有1个答案

李宜然
2023-03-14

数据/文件夹包含空的zookeeper/和kafka/目录

你创建了那些文件夹吗?Kafka的日志。目录只能包含主题分区或主题分区格式的文件夹。唯一ID删除(如果标记为删除),如错误所述。如果开始新安装,该文件夹应为空(无子文件夹)。

另外,Kafka数据目录不应该保存ZooKeer数据,因为ZooKeer应该独立于Kafka

 类似资料:
  • 本文向大家介绍简述Kafka的日志目录结构相关面试题,主要包含被问及简述Kafka的日志目录结构时的应答技巧和注意事项,需要的朋友参考一下 每个partition一个文件夹,包含四类文件.index .log .timeindex leader-epoch-checkpoint .index .log .timeindex 三个文件成对出现 前缀为上一个segment的最后一个消息的偏移 log文

  • 我找不到任何可以添加到Kafka的与配置相关的更改

  • 如何更改Springboot Kafka的日志记录?我在我们的Splunk服务器上看到了超过200万条消息,但什么都不起作用: 还尝试了: 依赖性: 这些都没有任何作用。我错过什么了吗?

  • 我在一个输入主题上构建KTable,并且在两个Kafka Stream应用程序实例上加入KStream。 KTable的输入主题已经是一个日志压缩主题。因此,当我的一个应用程序实例关闭时,通过读取input log compacted主题,另一个实例状态存储似乎会用整个状态刷新。 所以不需要为我的KTable存储启用日志记录(更改日志)? 我的源输入日志压缩主题可能有数百万条记录,所以如果我在KT

  • 我在windows中启动Kafka服务器时遇到问题 命令\bin\windows\kafka服务器启动。球棒\配置\服务器。属性 错误消息: 该命令的语法不正确。错误:无法找到或加载主类文件\IBM\WebSphere 知道吗?

  • 1)我在机器上启动Kafka 2)我用配置启动Spring Boot服务器: 1)为什么会发生这种情况? 2)我必须创建吗?为什么不需要本地Kafka? 埃德迪特