举个栗子:CentOS 7上安装kafka教程

kafka是一种经常使用的消息队列,可以将数据持久化到消息队列中,可以随时进行消费。同时消息队列的使用可以减少代码的耦合度,因为消息队列接口的开发可以独立于业务系统而存在。kafka以其灵活性、扩展性、可恢复性以及异步通信的特点在开发中得到了广泛的应用,下面小编为大家介绍CentOS 7上安装kafka,在此之前需要Linux服务器上已安装了jdk并且配置了jdk的环境变量。同时需要安装好zookeeper,zookeeper的安装请参考下文。

21CentOS 7上安装zookeeper教程

工具/原料

  • CentOS 7

方法/步骤

  1. 1

    首先我们需要下载kafka的压缩包,下载完成后将该压缩包上传到CentOS 7的目录中我们使用tar命令解压,然后使用cd命令进入到解压后的目录中,在该目录中使用mkdir命令创建kafkaLogs用于存放日志,如下图所示。

    CentOS 7上安装kafka教程

  2. 2

    接着我们在kafka的解压缩目录下找到config目录,cd config进入到该目录后,找到server.properties文件,该文件便是kafka的配置文件,如下图所示。其他broker.id=0为该机器的唯一标识,若需要安装kafka集群,则其他的机器需要修改这个broker.id。listeners配置的为本机localhost的9092端口,这是kafka的默认端口,localhost可以该为本机的IP地址或者hostname,也可以不使用9092这个默认的端口。

    CentOS 7上安装kafka教程CentOS 7上安装kafka教程

  3. 3

    接下来修改log.dirs为上一步创建的kafkaLogs目录的路径。由于zookeeper是用来管理kafka集群的,我们还需要在配置文件中添加zookeeper的配置,如下图所示。我们的zookeeper和kafka是安装在同一台机器上的,因此zookeeper.connect=localhost:2181,其中2181是zookeeper的默认端口,若安装在不同的机器上则localhost要修改为该机器的IP地址或者hostname,使用hostname是请注意必须要在本机上配置该hostname,我们使用vi /etc/hosts文件即可。

    CentOS 7上安装kafka教程CentOS 7上安装kafka教程

  4. 4

    接下来我们需要将kafka配置到环境变量中,我们使用vi /etc/profile命令打开配置文件,增加kafka的配置即可,然后使用source /etc/profile命令,使得修改生效,如下图所示。

    CentOS 7上安装kafka教程

  5. 5

     我们在kafka的bin目录下执行nohup ./kafka-server-start.sh ./config/server.properties 1>/dev/null &命令后台启动kafka,然后使用./kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test来创建topic,并指定toipc的备份数、分区数,如下图所示。

    CentOS 7上安装kafka教程

  6. 6

    kafka启动后我们可以使用java的jps命令查看kafka的进程,结果如下图所示。

    CentOS 7上安装kafka教程END

注意事项

  • 配置文件中在使用hostname时需要在本机中添加该hostname
  • 在windows系统中访问hostname时也需要在hosts文件中添加该hostname
© 版权声明
THE END
点赞0
抢沙发
头像
提交
头像

昵称

取消
昵称
一言一语