跟我学Kafka源码使用入门(三)

这一节咱们主要是讨论单机版的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的源码分析之路。

上一篇:【图像识别】基于模板匹配算法实现手势识别Matlab代码


下一篇:【图像分割】基于粒子群优化模糊聚类算法实现图像分割matlab代码