搜文章
推荐 原创 视频 Java开发 iOS开发 前端开发 JavaScript开发 Android开发 PHP开发 数据库 开发工具 Python开发 Kotlin开发 Ruby开发 .NET开发 服务器运维 开放平台 架构师 大数据 云计算 人工智能 开发语言 其它开发
Lambda在线 > 超仔个人空间 > kafka学习(一安装)

kafka学习(一安装)

超仔个人空间 2018-03-01

        今天记录下自己开始学习kafka的经验,首先我们先说在windows环境下的安装部署。

        安装很简单只需要下载kafka大家可以去官网自行下载,我这里下载的是kafka_2.12-1.0.0下载完成后我们解压到指定文件夹下面F:\eclipse-oxy\kafka我自己新建的路径,进入F:\eclipse-oxy\kafka\kafka_2.12-1.0.0\config这里面有两个可能会用到的配置文件一个是zookeeper.properties另一个是server.properties

第一个是启动zookeeper的一个是启动kafka的。

        其中zookeeper.properties中我只修改了dataDir=F:/eclipse-oxy/kafka/logs/zookeeper,server.properties我只修改了

log.dirs=F:/eclipse-oxy/kafka/logs/kafka

其中zookeeper.connect=localhost:2181这是需要注意的地方

配置完成后我们就可以启动了,首先启动zookeeper,进入到F:\eclipse-oxy\kafka\kafka_2.12-1.0.0目录

执行.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

看到结果

启动成功了。

然后启动kafka进入到F:\eclipse-oxy\kafka\kafka_2.12-1.0.0目录

执行 .\bin\windows\kafka-server-start.bat .\config\server.properties

kafka学习(一安装)

启动完成如果失败建议删除F:\eclipse-oxy\kafka\kafka_2.12-1.0.0\eclipse-oxykafkalogskafka下的文件

然后创建topic

执行 bin\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

partitions 分区

replication-factor表示该topic需要在不同的broker中保存几份,这里replication-factor设置为1, 表示在一个broker中保存。 

剩下的就是生产者和消费者的代码了

生产者:

kafka学习(一安装)


消费者:

props.put("group.id", "0");其中如果启动两个相同的grou.id则只有一个消费者可以收到信息,如果想都收到就要创建多个group.id就是说一个组中一个消费者消费某一个topic今天就说到这里后面再讲其他的。

感兴趣的小伙伴们多转发也可以关注我提出你的问题和建议,让我一起学习进步。



版权声明:本站内容全部来自于腾讯微信公众号,属第三方自助推荐收录。《kafka学习(一安装)》的版权归原作者「超仔个人空间」所有,文章言论观点不代表Lambda在线的观点, Lambda在线不承担任何法律责任。如需删除可联系QQ:516101458

文章来源: 阅读原文

相关阅读

关注超仔个人空间微信公众号

超仔个人空间微信公众号:gh_89ab0fc03e0c

超仔个人空间

手机扫描上方二维码即可关注超仔个人空间微信公众号

超仔个人空间最新文章

精品公众号随机推荐