跟我学Kafka源码使用入门(三)
2016-07-06 15:26
197 查看
这一节咱们主要是讨论单机版的Kafka的简单使用,关于集群方面的东西其实也非常简单,具体可以参考Kafka官网进行配置既可。
1、准备Zookeeper环境
我们使用的是zookeeper-3.5.0版本。
使用./zkServer.sh start命令启动Zookeeper
使用ps -ax | grep zookeeper命令,出现下图所示:
2、准备Kafka环境
我们使用的是kafka_2.10-0.8.2.1版本。
修改config/server.properties文件
找到host.name设置为127.0.0.1
启动Kafka服务 ./kafka-server-start.sh -daemon ../config/server.properties
创建Kafka的topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testKJ1
启动Kafka consumer监控端
./kafka-console-consumer.sh -zookeeper localhost:2181 --from-beginning --topic testKJ1
3、编写JAVA Producer代码
启动如下代码:
4、Kafka consumer控制台
可以看到下图在consumer端不断的滚动producer发送来的数据。
本节我们介绍了Kafka的使用基础,为我们正式进行源码分析打下了基础,在下一节中,咱们正式开始进行Kafka的源码分析之路。
1、准备Zookeeper环境
我们使用的是zookeeper-3.5.0版本。
使用./zkServer.sh start命令启动Zookeeper
使用ps -ax | grep zookeeper命令,出现下图所示:
2、准备Kafka环境
我们使用的是kafka_2.10-0.8.2.1版本。
修改config/server.properties文件
找到host.name设置为127.0.0.1
启动Kafka服务 ./kafka-server-start.sh -daemon ../config/server.properties
创建Kafka的topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testKJ1
启动Kafka consumer监控端
./kafka-console-consumer.sh -zookeeper localhost:2181 --from-beginning --topic testKJ1
3、编写JAVA Producer代码
启动如下代码:
4、Kafka consumer控制台
可以看到下图在consumer端不断的滚动producer发送来的数据。
本节我们介绍了Kafka的使用基础,为我们正式进行源码分析打下了基础,在下一节中,咱们正式开始进行Kafka的源码分析之路。
相关文章推荐
- Kafka常用命令行总结
- 【转】MYSQL出错代码列表
- Scala学习笔记(一)
- Scala中的下划线的作用
- 跟我学Kafka源码Producer分析
- Scala class与Case class的区别
- Kafka整体结构以及模块分析
- rem 产生的小数像素问题
- 校外分散实习(1)
- Cookie Session
- Peeking Iterator
- Qt学习之路(27): 渐变填充
- Unity3D UGUI按钮长按事件
- 第一节:安装Python
- js 程序执行与顺序实现详解
- android透明状态栏
- rtmp协议详解
- ListView里面Item元素 文字乱串问题
- iOS小技巧-使用UUID+keychain替代udid方案
- JAVA字符串格式化-String.format()的使用