按照《初学者学习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
数据/文件夹包含空的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? 埃德迪特