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