admin 管理员组

文章数量: 1086019

kafka在windows下单机版搭建

kafka在windows下单机版搭建

1.win本地单机版搭建

1.1安装zookeeper环境

  • 下载地址

    Apache Downloads

  • 添加配置文件

    在config目录下复制一份zoo_sample.cfg文件到同级目录，然后更改名称为zoo.cfg

  • 添加如下配置内容

    tickTime=2000
initLimit=10
syncLimit=5
clientPort=2181
dataDir=D:\\environment\\apache-zookeeper-3.5.10-bin\\data
dataLogDir=D:\\environment\\apache-zookeeper-3.5.10-bin\\log
admin.serverPort=9999

    主要制定data和log路径已经端口号

  • 配置系统环境变量

    ZOOKEEPER_HOME 值对应zookeeper目录

    path添加一个 %ZOOKEEPER_HOME%\bin

  • 启动bin目录下zkServer.cmd

    注：如果遇到闪退可以百度，很多解决办法

2.2安装kafka环境

  • 下载地址

    Apache Kafka

  • 修改config目录下的server.properties

    broker.id=0numwork.threads=3# The number of threads that the server uses for processing requests, which may include disk I/O
num.io.threads=8# The send buffer (SO_SNDBUF) used by the socket server
socket.send.buffer.bytes=102400# The receive buffer (SO_RCVBUF) used by the socket server
socket.receive.buffer.bytes=102400# The maximum size of a request that the socket server will accept (protection against OOM)
socket.request.max.bytes=104857600log.dirs=D:\environment\kafka_2.12-2.2.0\logsnum.partitions=1num.recovery.threads.per.data.dir=1offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168log.segment.bytes=1073741824log.retention.check.interval.ms=300000zookeeper.connect=localhost:2181zookeeper.connection.timeout.ms=6000group.initial.rebalance.delay.ms=0

    由于是单机版，所以主要修改log.dirs路径，zookeeper.connect值

  • 启动kafka

    第一步：进入bin下的windows

    第二步：在路径框输入cmd

    第三步：在cmd中输入kafka-server-start.bat ..\..\config\server.properties

2.3测试安装是否成功（以案例形式展示）

2.3.1创建一个topic 取名test

在bin\windows目录下打开cmd
.\kafka-console-producer.bat --broker-list localhost:9998 --topic test

2.3.2创建一个消费者

在bin\windows目录下打开cmd.\kafka-console-consumer.bat --bootstrap-server localhost:9998 --from-beginning --topic test

2.3.3成功结果

在生产者窗口输入内容，消费者窗口就会收到消息即是成功

本文标签： kafka在windows下单机版搭建

版权声明：本文标题：kafka在windows下单机版搭建 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.roclinux.cn/b/1693589714a230997.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。