Ubuntu18.04搭建kafka集群
时间:2019-05-20 19:33:30
小编:动力软件园
阅读:
下载地址:kafka
解压,修改文件夹名称
创建日志目录
进入config目录,修改server.properties
修改一下日志目录
先启动zeekeeper,然后启动kafka
后面的是刚刚修改的配置文件的路径
这里报了个错误,kafka-run-class.sh找不到java
这里要重新执行一下
source /etc/profile
然后就行了
创建Topic,打开另一个tab
列出所有Topic
启动生产者Producer并发送消息
启动消费者Consumer接受消息
使用下面的命令就可以了。
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
停止kafka
./kafka-server-stop.sh
kafka一些常用命令
1)、启动kafka命令:
cd /opt/kafka_2.10-0.10.1.1/bin;
./kafka-server-start.sh /opt/kafka_2.10-0.10.1.1/config/server.properties
(2)、停止kafka命令:
./kafka-server-stop.sh
(3)、创建Topic:(创建一个名为test的topic,只有一个副本,一个分区。)
./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
(4)、列出所有Topic:
./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
(5)、启动Producer并发送消息:
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
(输入相应的消息,eg:hello kafka;按Ctrl+C结束)
(6)、启动Consumer并接收消息:
./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning
-
Ubuntu环境搭建FTP服务器教程FTP上传和下载工具,多适用于网站管理人员使用,软件支持 SSL/TLS 协议、Sever 对Sever 对传(FXP)、拖曳功能、档案编辑检视、上传下载续传、防火墙、自订命令、网址解析等多种功能,可以方便用户连接远程服务器进行文件的管理操作,支持32位和64位操作系统。时间:2019-04-07
热门阅读
-
网易实名认证怎么解除 网易实名认证解除方法
阅读:7376
-
百度网盘怎么看广告加速 百度网盘看广告加速方法
阅读:6400
-
全面战争三国怎么征兵 全面战争三国征兵技巧
阅读:60
-
携号转网失败怎么办 携号转网失败解决方法
阅读:2387
-
迅雷下载引擎未启动是怎么回事 迅雷下载引擎未启动解决方法
阅读:18673