kafka环境搭建测试

一、安装

1. 下载:去kafka官网下载:https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz

2. 解压:tar -xzf kafka_2.11-0.9.0.1.tgz

3. 修改配置文件:

3.1 server.properties:

host.name=l92.168.242.131 (将localhost改为实际的IP地址)

advertised.host.name=l92.168.242.131

3.2 consumer.properties

zookeeper.connect=l92.168.242.131:2181 (将localhost改为实际的IP地址)

3.3 producer.properties

metadata.broker.list=l92.168.242.131:9092 (将localhost改为实际的IP地址)

3.4 zookeeper.properties

maxClientCnxns=100 (改为大于0)

4.启动

4.1 启动zookeeper

./zkServer.sh start

4.2 启动kafka

./kafk-server-start.sh ../config/server.properties&

4.3验证zk中broker的信息是否正确

get /broker/ids/0

 {"jmx_port":-1,"timestamp":"1428512949385","endpoints":["PLAINTXT://192.168.242.131:9092"],"host":"192.168.242.131","version":1,"port":9092}

如果结果为中实际的IP地址而不是localhost则正确

5.创建topic

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

6.查询topic

> bin/kafka-topics.sh --list --zookeeper 192.168.242.131:2181

7.发送消息

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

8.收消息

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

可以一个终端中运行consumer命令行,另一个终端中运行producer命令行,这样就可以在一个终端输入消息,另一个终端读取消息。

时间: 2024-11-05 06:30:29

kafka环境搭建测试的相关文章

kafka环境搭建二---Windows客户端Linux服务器

一.对于服务器端的搭建可以参考上一篇文章:kafka单机版环境搭建与测试 服务器端IP :10.0.30.221 运行环境的目录如下: 需要改动config文件夹下的server.properties中的以下两个属性 zookeeper.connect=localhost:2181改成zookeeper.connect=10.0.30.221:2181 以及默认注释掉的 #host.name=localhost改成host.name=10.0.30.221 host.name不更改会造成客户端报

Hadoop 2.x伪分布式环境搭建测试

Hadoop 2.x伪分布式环境搭建测试 标签(空格分隔): hadoop hadoop,spark,kafka交流群:459898801 1,搭建hadoop所需环境 卸载open JDK rpm -qa |grep java rpm -e –nodeps [java] 1.1,在/opt/目录下创建四个目录: modules/ software/ datas/ tools/ 解压hadoop-2.5.0及jdk-7u67-linux-x64.tar.gz至modules目录下. $tar -

Nginx配置多个基于域名的虚拟主机+实验环境搭建+测试

标签:Linux 域名 Nginx 原创作品,允许转载,转载时请务必以超链接形式标明文章 原始出处 .作者信息和本声明.否则将追究法律责任.http://xpleaf.blog.51cto.com/9315560/1901284 0.说明 使用Nginx可以配置基于域名的虚拟主机.基于端口的虚拟主机和基于端口的虚拟主机,比较常用的是基于域名的虚拟主机,这里要做的配置是基于域名的虚拟主机,并且是配置多个基于域名的虚拟主机. 关于Nginx配置文件的说明可以参考官方文档,同时也可以参考老男孩老师的书

ajax+php(环境搭建+测试)

在学习JavaScript,jQuery的ajax部分的时候,一直不明白要如何进行,不知道服务器要怎么弄,什么都不知道,当初在学ajax的时候,除了看一下ajax的内容,实践极少,因为,不知道要怎么做. 现在,如何来实践ajax,如何实现前后端的交互,我这里选择的Apache+PHP+mysql.并且,我这里安装的各个版本都是很早以前的版本,选这个是因为安装过程比较简单,不过是相对比较简单,虽然早,但是对于一般的测试还是够用的. 搭建Apache + php+MySQL 平台 这是我在本地形成的

kafka环境搭建2-broker集群+zookeeper集群(转)

原文地址:http://www.jianshu.com/p/dc4770fc34b6 zookeeper集群搭建 kafka是通过zookeeper来管理集群.kafka软件包内虽然包括了一个简版的zookeeper,但是感觉功能有限.在生产环境下,建议还是直接下载官方zookeeper软件. 下载 最新版的zookeeper软件 wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.8/zookeeper-3.4.8.tar.g

Kafka 环境搭建

基础环境 CentOS-7-x86_64-DVD-1908 1.安装配置jdk下载安装包并解压配置环境变量jdk-8u231-linux-x64.tar.gz配置环境变量修改文件vi /etc/profile尾部添加export JAVA_HOME=/gcl/jdk1.8.0_231export JRE_HOME=${JAVA_HOME}/jreexport CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/libexport PATH=${JAVA_HOME}/

在CentOS上编译安装Nginx+实验环境搭建+测试

0.说明 Nginx作为一款优秀的Web Server软件同时也是一款优秀的负载均衡或前端反向代理.缓存服务软件,很有必要搭建实验环境来对其进行学习. 1.实验环境 本次实验的测试环境使用的宿主机操作系统为Windows 7,在Vmware虚拟机安装CentOS 6.5,说明如下: 宿主机操作系统Windows 7 虚拟机安装的操作系统CentOS 6.5 虚拟机操作系统上网方式NAT 而当使用NAT的方式进行上网时虚拟机.宿主机之间的网络连接关系可如下所示: 关于为什么网络拓扑结构是这样的,这

LAMP+LNMP(五)LAMP环境搭建测试

按顺序安装LAMP三个组件后,LAMP的环境的基础程序就已经搭建完毕了.接下来我们要把各个模块铆接起来并测试其工作是否正常. 一.Apache2.4与PHP5的结合 1.修改Apache2.4的配置文件 vim /usr/local/apache2.4/conf/httpd.conf #httpd的配置文件安装时默认设置在这个路径下 一共要修改四处地方:a.给sever设置一个severname这一步主要是用来解决httpd启动时的告警信息,如下图:设置方法找到SeverName行,将#Serv

hibernate 环境搭建测试

对于hibernate的介绍,网络上一搜一堆,恐怕我写的也没前辈总结的好. 这个博主总结的十分好,方便大家欣赏  http://blog.csdn.net/liujiahan629629/article/details/21442607 真正要掌握,还得需要自己动手,才能丰衣足食. 所需jar包 jar包版本不同,找的地址也不同.这里用到的是 hibernate-release-5.2.10 版本的jar包 除了这些jar包,还需要数据库驱动jar,根据自己用的数据库自定,这里用到的是oracl