本部署使用的版本为kafka_2.8.0-0.8.0。
参考了http://blog.csdn.net/itleochen/article/details/17451455这篇博文;
并根据官网介绍http://kafka.apache.org/documentation.html#quickstart完成。
废话少说,直接上步骤
1.下载kafka_2.8.0-0.8.0.tar.gz
https://archive.apache.org/dist/kafka/0.8.0/kafka_2.8.0-0.8.0.tar.gz
2.解压缩
tar -vxf kafka_2.8.0-0.8.0.tar.gz
3.修改配置文件
修改conf/server.properties
host.name=10.10.224.12 (修改为主机ip,不然服务器返回给客户端的是主机的hostname,客户端并不一定能够识别)
修改conf/zookeeper.properties 属性文件
dataDir=/usr/local/tmp/zookeeper (zookeeper临时数据文件)
4.启动zookeeper和kafka
cd bin
启动zookeeper
./zookeeper-server-start.sh ../config/zookeeper.properties & (&推出命令行,服务守护执行)
启动kafka
./kafka-server-start.sh ../config/server.properties &
5.验证是否成功
*创建主题
./kafka-create-topic.sh --partition 1 --replica 1 --zookeeper localhost:2181 --topic test
检查是否创建主题成功
./kafka-list-topic.sh --zookeeper localhost:2181
*启动produce
./bin/kafka-console-producer.sh --broker-list 10.10.224.12:9092 --topic test
*启动consumer
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
6.关闭kafka和zookeeper
./kafka-server-stop.sh ../config/server.properties
./zookeeper-server-stop.sh
心得总结:
1.produce启动的时候参数使用的是kafka的端口而consumer启动的时候使用的是zookeeper的端口;
2.必须先创建topic才能使用;
3.topic本质是以文件的形式储存在zookeeper上的。
如有误,望指正!
分享到:
相关推荐
kafka jar包,可用于jmeter
例如,在Linux环境下,可以使用命令`tar -zxvf kafka_2.8.0-0.8.0.tar.gz -C /home/hadoop/kafka`完成解压工作。 2. 配置环境变量:为了在命令行中方便使用Kafka相关命令,需要设置Kafka的安装目录环境变量KAFKA_...
环境:window7 64位,zookeeper3.4.6 kafka版本:kafka_2.8.0-0.8.0 window 搭建开发kafka集群:我的集群目录:F:\liuzhiwen\cluster\tech\kafka_cluster 需要切换到指定的目录:命令行切换cd F:\liuzhiwen\cluster\...
- `kafka_2.8.0-0.8.0.jar`:Kafka的核心库。 - `sbt-launch.jar`:Scala构建工具SBT的启动脚本。 - `scala*.jar`:Scala语言相关的库。 - `zkclient-0.1.jar`:Zookeeper客户端库。 2. **配置Flume-ng**: - ...
ule子模块卡夫卡 ...Kafka依赖关系需要安装在本地存储库中mvn install:install-file -Dfile = kafka_2.8.0-0.8.0.jar -DgroupId = kafka -DartifactId = kafka -Dversion = 0.8.0 -Dpackaging = jar
在下载 Kafka 0.8 时,需要注意选择适合自己操作系统的版本,例如 `kafka_2.8.0-0.8.0` 文件名表示的是针对 Java 2.8.0 的版本。下载后,需要按照官方文档的指导进行配置和启动,才能开始使用 Kafka 的功能。 总结...