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

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏GreenLeaves

Oracle 删除监听程服务

1、开始->运行->输入regidit -> ? -> ? -> ? -> ? -> ? 红框内的右键删除 2、开始->运行->输入regidit -> ? -...

3958
来自专栏软件开发 -- 分享 互助 成长

openfire的配置

Openfire 采用Java开发,开源的实时协作(RTC)服务器基于XMPP(Jabber)协议。Openfire安装和使用都非常简单,并利用Web进行管理。...

24410
来自专栏前端真相

手把手教你安装Redhat 7

2376
来自专栏我的博客

rpm管理入门

1、RPM特点:可升级性(升级之后配置文件被保留)、强大的查询功能、系统校验、纯净源码 RPM软件包命令的使用:安装、卸载、刷新、升级、查询 安装 rpm -i...

2724
来自专栏深度学习之tensorflow实战篇

Hadoop查看所有JOB以及如何Kill指定用户的所有Job

如何kill掉制定用户的所有job,有没有现成的命令?我看了一下hadoop job命令的提示,没有这样的命令。 其实实现kill指定用户的job也非常简单,本...

3066
来自专栏机器学习实践二三事

pip安装报错'not a supported wheel on this platform'

这个错误很常见,解决方法是改名,首先要获得在你的机器的平台上的合法名称: import pip pip.pep425tags.get_supporte...

2647
来自专栏深度学习之tensorflow实战篇

python生成exe,环境win10简单的小程序案例

1.直接pip安装:pip install pyinstaller ? 2.打包时,在命令行中切换到要打包的程序所在目录,直接输入下面的指令即可。 ...

3775
来自专栏从零学习云计算

openshift/origin学习记录(11)——赋予用户集群管理员权限

由于system:admin默认没有密码,没法登录web console,这里通过指令给账号dev赋予集群管理员权限。 # oc login -u sys...

3190
来自专栏啸天"s blog

Caddy 一键反代谷歌安装脚本

3523
来自专栏王小雷

React Natvie在Mac os上安装并创建项目

详细记录React-Native 0.47版本在Mac OS 上安装过程并初始化项目。 ? 1. 安装RN环境 1.1 安装brew /usr/bin/ruby...

2236

扫码关注云+社区

领取腾讯云代金券