欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

kafka cmd首个单机例子配置

程序员文章站 2023-12-29 10:23:40
下载地址:http://kafka.apache.org/downloads http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz zookeeper.properties修改dataDir server.propertie ......

下载地址:       http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz

 

zookeeper.properties修改datadir

datadir=g:\zookeeper-3.5.5\data
# the port at which the clients will connect
clientport=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxclientcnxns=0

server.properties修改log.dirs

############################# log basics #############################

# a comma separated list of directories under which to store log files
log.dirs=g:\kafka\logs

 

运行zookeeper命令

zkserver

 

进入cd g:\kafka\bin\windows

 

启动服务:

kafka-server-start.bat ../../config/server.properties

创建实例

kafka-topics.bat --create --zookeeper localhost:2181 --repl
ication-factor 1 --partitions 1 --topic testdemo

 

生产者

kafka-console-producer.bat --broker-list localhost:9092 --t
opic testdemo

 

 

消费者

kafka-console-consumer.bat --bootstrap-server localhost:909
2 --topic testdemo --from-beginning

 

在生产者里输入内容,消费者就打印出相应内容

kafka cmd首个单机例子配置

上一篇:

下一篇: