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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,032评论 19 139
  • Kafka入门经典教程-Kafka-about云开发 http://www.aboutyun.com/threa...
    葡萄喃喃呓语阅读 10,890评论 4 54
  • 本文转载自http://dataunion.org/?p=9307 背景介绍Kafka简介Kafka是一种分布式的...
    Bottle丶Fish阅读 5,505评论 0 34
  • 一、基本概念 介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独...
    ITsupuerlady阅读 1,662评论 0 9
  • ** 今天看了一下kafka官网,尝试着在自己电脑上安装和配置,然后学一下官方document。** Introd...
    RainChang阅读 5,053评论 1 30