Kafka环境搭建之“地雷战”

 今天带大家踩一踩Kafka安装走过的坑,先安装一个单机版的Kafka玩玩

1、环境准备

     (1)虚拟机centos6 一台,安装教程小生这里就不赘述了

     (2) Kafka版本是 kafka_2.11-1.0.1,下载链接链接:https://pan.baidu.com/s/16RXxVzATR94N8r1w4u7DFg 提取码:1fxk 

     (3)zookeeper版本是3.4.8,下载链接http://archive.apache.org/dist/zookeeper/zookeeper-3.4.8/zookeeper-3.4.8.tar.gz

     (4) 安装之前呢,先关掉centos6自带的防火墙,避免报无谓的连接错误 依次输入命令  service iptables stop (关闭防火墙)

       chkconfig  iptables off (永久关闭防火墙)   chkconfig  iptables status(查看防火墙状态)  

Kafka环境搭建之“地雷战”

2、安装Zookeeper

     (1)将下载好的zookeeper的tar包上传至服务器解压后,进入安装后conf目录下,将zoo_sample,cfg,重命名为zoo.cfg

      Kafka环境搭建之“地雷战”

  (2)  打开zoo.cfg文件,修改dataDir目录(快照存放地址,随意指定目录即可),可以修改clientPort(zookeeper端口),小生这里就保持默认了

  Kafka环境搭建之“地雷战”

 (3)然后进入zookeeper/bin目录,输入./zkServer.sh start启动,然后可以通过./zkServer.sh status查看启动状态,Mode:standalone则为启动成功,代表单机版模式

Kafka环境搭建之“地雷战”

Kafka环境搭建之“地雷战”

3、安装Kafka

   Kafka本身是集成了zookeeper了的,但是小生这里就不用自带的了,因为后面做集群的时候也需要独立安装zookeeper

 (1)解压Kafka tar包,修改log.dirs的路径,大家可随意修改,然后修改zookeeper.connection为zookeeper安装的ip和端口

Kafka环境搭建之“地雷战”

Kafka环境搭建之“地雷战”

 

前台运行:(前台运行,当前窗口不可关闭,关闭后Kafka1停止了)

bin/kafka-server-start.sh config/server.properties

后台运行:

nohup bin/kafka-server-start.sh config/server.properties > kafka-run.log 2>&1 &

4、运行调试

 

(1)创建kafka主题:(主题为test)

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Kafka环境搭建之“地雷战”

(2)显示kafka所有主题:

bin/kafka-topics.sh -list -zookeeper localhost:2181

Kafka环境搭建之“地雷战”

(3)创建kafka生产者:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

Kafka环境搭建之“地雷战”

(4)创建kafka消费者:(另外打开一个窗口)

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

Kafka环境搭建之“地雷战”

(5)测试

在生产者窗口输入数据,然后回车

Kafka环境搭建之“地雷战”

消费者窗口可查看到我们发送到的数据

Kafka环境搭建之“地雷战”

到此,Kafka的server就安装完成了,总的来说,安装还是相对简单的,大家都去试试吧

 

相关文章: