共计 1725 个字符,预计需要花费 5 分钟才能阅读完成。
一、环境操作系统和软件版本介绍
1. 环境操作系统为 CentOS Linux release 7.2.1511 (Core)
可用 cat /etc/RedHat-release 查询
2. 软件版本
Kafka 版本为:0.10.0.0
二、详细安装步骤
1. 下载 kafka_2.10-0.10.0.0.tgz 到 /data/soft 目录
2. 将 kafka_2.10-0.10.0.0.tgz 解压到 /data/app/Kafka 目录
1 [root@centos7 kafka_2.10-0.10.0.0]# tar –xzf kafka_2.10-0.10.0.0.tgz –C /data/app/Kafka
3. 进入解压目录 (在此为 /data/app/Kafka/kafka_2.10-0.10.0.0/bin),启动 zookeeper 服务。可以在命令的结尾加个 & 符号,这样服务就可以在后台运行
1 [root@centos7 kafka_2.10-0.10.0.0]# ./zookeeper-server-start.sh ../config/zookeeper.properties &
4. 启动 kafka 服务
[root@centos7 kafka_2.10-0.10.0.0]# ./kafka-server-start.sh ../config/server.properties &
[root@centos7 bin]# ps -ef | grep kafka 查看,观察到 zookeeper 和 kafka 服务已启动
三、验证
1. 创建一个叫 ”test1234″ 的 topic,它只有一个分区,一个副本:
[root@centos7 bin]# ./kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test1234
可以用 list 查看创建的 topic,当前创建了 4 个 topic
[root@centos7 bin]# ./kafka-topics.sh –list –zookeeper localhost:2181
2. 发送消息。运行 producer 并在控制台中输一些消息,这些消息将被发送到服务端
[root@centos7 bin]# ./kafka-console-producer.sh –broker-list localhost:9092 –topic test1234
3. 在另一个终端开启 consumer,可以读取到刚才发出的消息并输出。
[root@centos7 bin]# ./kafka-console-consumer.sh –zookeeper localhost:2181 –topic test1234 –from-beginning
CentOS 7.2 部署 Elasticsearch+Kibana+Zookeeper+Kafka http://www.linuxidc.com/Linux/2016-11/137636.htm
CentOS 7 下安装 Logstash ELK Stack 日志管理系统 http://www.linuxidc.com/Linux/2016-08/134165.htm
Apache Kafka 代码实例 http://www.linuxidc.com/Linux/2013-11/92754.htm
Apache Kafka 教程笔记 http://www.linuxidc.com/Linux/2014-01/94682.htm
Apache kafka 原理与特性 (0.8V) http://www.linuxidc.com/Linux/2014-09/107388.htm
Kafka 部署与代码实例 http://www.linuxidc.com/Linux/2014-09/107387.htm
Kafka 介绍和集群环境搭建 http://www.linuxidc.com/Linux/2014-09/107382.htm
Kafka 的详细介绍 :请点这里
Kafka 的下载地址 :请点这里
本文永久更新链接地址 :http://www.linuxidc.com/Linux/2017-01/139732.htm