刘总的笔记小站

生活常识,娱乐搞笑,编程技巧,智能家居,深度学习,网络神经,数据挖掘

kafka2.8.1版本 搭建部署启动kafka

kafka2.8.1版本 搭建部署启动kafka

(一):搭建部署

在新发布的kafka2.8.0版本中,已经可以不启动zk就可以使用kafka了,
在config目录下多了一个kraft目录,在该目录中有一套新的配置文件,可以直接脱离ZooKeeper运行。

修改配置

到config下kraft目录中修改server.properties文件,单机的话主要是修改下面的配置

advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kraft-combined-logs


(二):启动kafka

通过现在三行命令,即可开启一个单机的broker

./bin/kafka-storage.sh random-uuid
./bin/kafka-storage.sh format -t 1DViwWWpQf63N6bhJFAgzQ -c ./config/kraft/server.properties
./bin/kafka-server-start.sh ./config/kraft/server.properties
#后台启动
./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties


创建topic

./bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

查看topic信息

./bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092

删除topic

./bin/kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092

发送消息

./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

消费消息

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning


################################################
OTHER:

bin/kafka-storage.sh random-uuid > uuid
bin/kafka-storage.sh format -t `cat uuid` -c config/kraft/server.properties
bin/kafka-server-start.sh -daemon config/kraft/server.properties
bin/kafka-topics.sh --create --topic foo --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092


################################################




发表评论:

控制面板
您好,欢迎到访网站!
  查看权限
搜索
«   2024年9月   »
1
2345678
9101112131415
16171819202122
23242526272829
30
网站分类
最新留言
文章归档
网站收藏
友情链接
图标汇集
Powered by Z-BlogPHP

  • Copyright ©2021 @liuzong All rights reserved.
  • 陕ICP备17016542号