修改任何配置文件时 如果原本文件中能找到,请替换内容即可
以防止出现重复问题
- 解压kafka压缩包。
- 配置server.properties
进入到config文件夹里面,找到server.properties文件,进行编辑,找到log.dirs,修改这个参数的路径为:
log.dirs=D:\\kafka\\kafka_2.13-3.2.1\\kafka-logs
(安装目录kefka-log)添加内容
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092
假如IP为127.0.0.1添加内容
message.max.bytes=5242880 #每个分区试图获取的消息字节数。要大于等于message.max.bytes replica.fetch.max.bytes=6291456 #原有的socket.send.buffer.bytes,socket.receive.buffer.bytes,socket.request.max.bytes也要改成和message.max.bytes一样的大小
以下为修改内容
# The send buffer (SO_SNDBUF) used by the socket server socket.send.buffer.bytes=5242880 # The receive buffer (SO_RCVBUF) used by the socket server socket.receive.buffer.bytes=5242880 # The maximum size of a request that the socket server will accept (protection against OOM) socket.request.max.bytes=104857600
producer.properties 中添加
#请求的最大大小为字节。要小于 message.max.bytes max.request.size = 5242880
consumer.properties 中添加
#每个提取请求中为每个主题分区提取的消息字节数。要大于等于message.max.bytes fetch.message.max.bytes=6291456
- 配置zookeeper.properties
进入到config文件夹里面,找到server.properties文件,进行编辑,找到dataDir,修改这个参数的路径为:
dataDir=D:\\kafka\\kafka_2.13-3.2.1\\zookeeper-data
(安装目录zookeeper-data)
- 启动zookeeper
- 打开cmd,进入kafka安装目录,执行:
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
- 启动kafka
- 再打开一个cmd,进入kafka安装目录,执行:
.\bin\windows\kafka-server-start.bat .\config\server.properties
- kafka和zooker正常启动之后,执行脚本createTopic.sh,创建topic
- 等待topic创建结束,启动接收服务jar包
本作品采用知识共享署名-非商业性使用 4.0 国际许可协议进行许可。
本文链接:https://www.blog.ycisch.com/archives/751.html
不错不错,我喜欢看 https://www.237fa.com/
想想你的文章写的特别好https://www.jiwenlaw.com/