`
sesame84
  • 浏览: 8333 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类

kafka的单机部署(针对kafka_2.8.0-0.8.0.)版本

阅读更多
本部署使用的版本为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上的。

如有误,望指正!
0
0
分享到:
评论

相关推荐

    kafka_2.8.2-0.8.0.jar

    kafka jar包,可用于jmeter

    kafka安装.pdf

    例如,在Linux环境下,可以使用命令`tar -zxvf kafka_2.8.0-0.8.0.tar.gz -C /home/hadoop/kafka`完成解压工作。 2. 配置环境变量:为了在命令行中方便使用Kafka相关命令,需要设置Kafka的安装目录环境变量KAFKA_...

    window 伪分布式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+Flume-ng搭建

    - `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**: - ...

    mule-module-kafka:适用于Apache Kafka的Mule平台集成

    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

    kafka0.8官网下载

    在下载 Kafka 0.8 时,需要注意选择适合自己操作系统的版本,例如 `kafka_2.8.0-0.8.0` 文件名表示的是针对 Java 2.8.0 的版本。下载后,需要按照官方文档的指导进行配置和启动,才能开始使用 Kafka 的功能。 总结...

Global site tag (gtag.js) - Google Analytics