centos 7下KAFKA简单配置使用

2018年08月16日 970点热度 0人点赞 0条评论

常用网址:
    KAFKA官网地址
    KAFKA下载地址



1、安装java环境



2、解压kafka压缩包,并修改两个配置文件

2.2.1 解压程序包到/opt/目录下,并做好符号链接,在其下创建zkdata数据目录

2.2.2 修改kafka配置文件server.properties中第32行和125行配置项,添加本机IP

2.2.3 修改zookeeper配置文件zookeeper.properties,16行data目录修改为刚才创建的zkdata的绝对路径,确认18行端口信息并在下面新增19行内容



3、启动zookeeper和kafka程序



4、其他常用命令

4.1 jps命令查看所有java进程pid
   QuorumPeerMain是ZooKeeper守护进程,kafka是kafka的守护进程


4.2 创建topic


4.3 查看所有topic列表


4.4 删除topic


4.5 启动生产者以发送消息


4.6 启动消费者以接收消息

使用ctrl + c中止运行后,会提示处理了几条消息


学习自w3cschool
完!


Chen

健康 · 开心 · 做自己

文章评论