跟我学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的源码分析之路。