KAFKA 0.11 RHEL6.5安装
2017-07-20 09:11
363 查看
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
相关文章推荐
- 【ASM】Oracle ASM + 11gR2 + RHEL6.5 安装
- rhel6.5安装OpenJDK1.7.0 + JBoss7.1.1 + maven3.0.4
- 基于RHEL 6.5安装Oracle 11g详细教程(8)——OVF模板制作
- RHEL6.5安装multipath多路径软件
- 解决VMware6.5 以上版本安装RHEL 5的自动安装的问题
- 在CentOS/RHEL 6.5上安装Chromium 谷歌浏览器
- 【静默】在RHEL 6.5上静默安装Oracle 18c
- RHEL 6.5系统安装配置图解教程(rhel-server-6.5)
- RHEL6.5 db2_data_server_client客户端 安装与配置
- RHEL6.5安装collectd5.8 采集数据至logstash
- RHEL 6.5系统安装配置图解教程(rhel-server-6.5)
- RHEL6.5安装multipath多路径软件
- RHEL 6.5系统安装配置图解教程(rhel-server-6.5)
- [rhel6.5]安装配置nagios本机监控,以及远程监控其他主机
- 在CentOS/RHEL 6.5上安装Chromium
- CentOS6.5安装Kafka
- centos/rhel 6.5(更新至centos 7)下rabbitmq安装(最简单方便的方式)
- RHEL 6.5上安装配置两个Tomcat
- RHEL 6.5系统安装配置图解教程(rhel-server-6.5)