首页 windows软件 手机软件 驱动下载 电脑教程 专题合集
当前位置: 首页 > 电脑教程 > 软件教程 > Ubuntu18.04搭建kafka集群

Ubuntu18.04搭建kafka集群

时间:2019-05-20 19:33:30

小编:动力软件园

阅读:

下载地址:kafka

解压,修改文件夹名称

创建日志目录

image.png


进入config目录,修改server.properties


image.png


修改一下日志目录


image.png


先启动zeekeeper,然后启动kafka

image.png

 

后面的是刚刚修改的配置文件的路径



image.png


这里报了个错误,kafka-run-class.sh找不到java

这里要重新执行一下

  source /etc/profile

然后就行了

创建Topic,打开另一个tab


image.png

列出所有Topic

image.png

启动生产者Producer并发送消息

image.png

 启动消费者Consumer接受消息


image.png


使用下面的命令就可以了。


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

停止kafka


 

./kafka-server-stop.sh

 


image.png


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服务器教程
    Ubuntu环境搭建FTP服务器教程
    FTP上传和下载工具,多适用于网站管理人员使用,软件支持 SSL/TLS 协议、Sever 对Sever 对传(FXP)、拖曳功能、档案编辑检视、上传下载续传、防火墙、自订命令、网址解析等多种功能,可以方便用户连接远程服务器进行文件的管理操作,支持32位和64位操作系统。
    时间:2019-04-07

火爆手游