KAFKA 0.11 RHEL6.5安装

KAFKA简介
KAFKA是一款分布式消息发布和订阅的系统。
官网:http://kafka.apache.org/
1、下载KAFKA及JDK
KAFKA下载地址:
http://kafka.apache.org/downloads ,下载binary类型的安装包。
下载后文件为:kafka_2.11-0.11.0.0.tgz
JDK下载地址:http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
下载后文件为:jdk-8u131-linux-x64.tar.gz

2、安装JDK
将JDK上传到/usr下,解压:
tar -xzvf jdk-8u131-linux-x64.tar.gz
设置变量:
vi .bash_profile
PATH中添加
/usr/jdk1.8.0_131/bin
使文件生效
source .bash_profile
3、修改hosts文件
添加主机地址映射
vi /etc/hosts

186.168.100.101 kafka
4、安装KAFKA
将KAFKA安装包上传到/opt下,解压:
tar -xzvf kafka_2.11-0.11.0.0.tgz

4、启动KAFKA
因为KAFKA是依赖zookeeper的,所以先开启zookeeper服务:
cd /opt/kafka_2.11-0.11.0.0
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
启动KAFKA服务:
nohup bin/kafka-server-start.sh config/server.properties &
5、测试KAFKA
打开两个terminal,一个作为消息发送端,一个作为消息接收端。
消息接收端执行以下命令,建立一个名为test的topic:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看消息接收端在运行的topic:
bin/kafka-topics.sh --list --zookeeper localhost:2181
消息发送端执行以下命令,向test发送消息:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
在消息接收端,执行以下命令查看收到的消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
6、KAFKA通信示例
在消息接收端执行以下命令,等待消息:
[root@kafka kafka_2.11-0.11.0.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

在消息发送端执行以下命令,并输入消息:hello:
[root@kafka kafka_2.11-0.11.0.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>hello
在消息接收端,查看收到的消息:
[root@kafka kafka_2.11-0.11.0.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
hello
上一篇:一种解决h5页面背景音乐不能自动播放的方案


下一篇:Java中利用Math.random()产生服从泊松分布的随机数