当前位置： 首页 > news >正文 免费网站建潍坊网站建设公司 news 2025/10/25 5:45:05 免费网站建,潍坊网站建设公司,怎么看一个网站谁做的优化,网站信息化建设建议和意见Kafka 实战教程#xff08;二#xff09; 1.下载2.安装3.配置4.运行4.1 启动 Zookeeper4.2 启动 Kafka 5.第一个消息5.1 创建一个 Topic5.2 创建一个消息消费者5.3 创建一个消息生产者 1.下载 你可以在 Kafka 官网#xff1a;http://kafka.apache.org/downloads#xff0c… Kafka 实战教程二 1.下载2.安装3.配置4.运行4.1 启动 Zookeeper4.2 启动 Kafka 5.第一个消息5.1 创建一个 Topic5.2 创建一个消息消费者5.3 创建一个消息生产者 1.下载 你可以在 Kafka 官网http://kafka.apache.org/downloads下载到最新的 Kafka 安装包选择下载二进制版本的 tgz 文件这里我们选择的版本是 kafka_2.11-1.1.0。 2.安装 Kafka 是使用 Scala 编写的运行于 JVM 上的程序虽然也可以在 Windows 上使用但是 Kafka 基本上是运行在 Linux 服务器上因此我们这里也使用 Linux 来开始今天的实战。 首先确保你的机器上安装了 JDKKafka 需要 Java 运行环境以前的 Kafka 还需要 Zookeeper新版的 Kafka 已经内置了一个 Zookeeper 环境所以我们可以直接使用。 说是安装如果只需要进行最简单的尝试的话我们只需要解压到任意目录即可这里我们将 Kafka 压缩包解压到 /home 目录。 3.配置 在 Kafka 解压目录下有一个 config 文件夹里面放置的是我们的配置文件。 consumer.properites消费者配置这个配置文件用于配置消费者此处我们使用默认的即可。 producer.properties生产者配置这个配置文件用于配置生产者此处我们使用默认的即可。 server.properties kafka服务器的配置此配置文件用来配置 Kafka 服务器目前仅介绍几个最基础的配置。 broker.id申明当前 Kafka 服务器在集群中的唯一 ID需配置为 integer并且集群中的每一个 Kafka 服务器的 id 都应是唯一的我们这里采用默认配置即可。listeners申明此 Kafka 服务器需要监听的端口号如果是在本机上跑虚拟机运行可以不用配置本项默认会使用 localhost 的地址如果是在远程服务器上运行则必须配置例如listenersPLAINTEXT://192.168.180.128:9092并确保服务器的 9092 9092 9092 端口能够访问。zookeeper.connect申明 Kafka 所连接的 Zookeeper 的地址 需配置为 Zookeeper 的地址由于本次使用的是 Kafka 高版本中自带 Zookeeper使用默认配置即可 zookeeper.connectlocalhost:2181。 当我们有多个应用在不同的应用中都使用 Zookeeper都使用默认的 zk 端口的话就会 2181 2181 2181 端口冲突。我们可以设置自己的端口号在 config 文件夹下 zookeeper.properties 文件中修改为 clientPort2185也就是 zk 开放接口为 2185 2185 2185。 同时修改 Kafka 的接入端口server.properties 文件中修改为 zookeeper.connectlocalhost:2185。这样我们就成功修改了 Kafka 里面的端口号。 4.运行 4.1 启动 Zookeeper cd 进入 kafka 解压目录输入如下命令 bin/zookeeper-server-start.sh config/zookeeper.properties启动 zookeeper 成功后会看到如下输出 4.2 启动 Kafka cd 进入 kafka 解压目录输入如下命令 bin/kafka-server-start.sh config/server.properties启动 kafka 成功后会看到如下输出 5.第一个消息 5.1 创建一个 Topic Kafka 通过 Topic 对同一类的数据进行管理同一类的数据使用同一个 Topic 可以在处理数据时更加的便捷。 在 kafka 解压目录打开终端输入以下命令创建一个名为 test 的 Topic。 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test在创建 Topic 后可以通过输入以下命令来查看已经创建的 Topic。 bin/kafka-topics.sh --list --zookeeper localhost:21815.2 创建一个消息消费者 在 kafka 解压目录打开终端输入以下命令 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning可以创建一个用于消费 Topic 为 test 的消费者。 消费者创建完成之后因为还没有发送任何数据因此这里在执行后没有打印出任何数据。不过别着急不要关闭这个终端打开一个新的终端接下来我们创建第一个消息生产者。 5.3 创建一个消息生产者 在 kafka 解压目录打开一个新的终端输入以下命令 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test在执行完毕后会进入编辑器页面。 在发送完消息之后可以回到我们的消息消费者终端中可以看到终端中已经打印出了我们刚才发送的消息。 文章转载自： http://www.morning.qrpx.cn.gov.cn.qrpx.cn http://www.morning.wslpk.cn.gov.cn.wslpk.cn http://www.morning.cwjsz.cn.gov.cn.cwjsz.cn http://www.morning.thxfn.cn.gov.cn.thxfn.cn http://www.morning.hhpkb.cn.gov.cn.hhpkb.cn http://www.morning.rjmd.cn.gov.cn.rjmd.cn http://www.morning.lbbyx.cn.gov.cn.lbbyx.cn http://www.morning.tbksk.cn.gov.cn.tbksk.cn http://www.morning.snbry.cn.gov.cn.snbry.cn http://www.morning.rjjys.cn.gov.cn.rjjys.cn http://www.morning.dwwlg.cn.gov.cn.dwwlg.cn http://www.morning.rdlxh.cn.gov.cn.rdlxh.cn http://www.morning.nlywq.cn.gov.cn.nlywq.cn http://www.morning.cokcb.cn.gov.cn.cokcb.cn http://www.morning.sqyjh.cn.gov.cn.sqyjh.cn http://www.morning.dqpd.cn.gov.cn.dqpd.cn http://www.morning.qwbht.cn.gov.cn.qwbht.cn http://www.morning.lwhsp.cn.gov.cn.lwhsp.cn http://www.morning.wxlzr.cn.gov.cn.wxlzr.cn http://www.morning.llllcc.com.gov.cn.llllcc.com http://www.morning.ruifund.com.gov.cn.ruifund.com http://www.morning.zglrl.cn.gov.cn.zglrl.cn http://www.morning.gdgylp.com.gov.cn.gdgylp.com http://www.morning.tdldh.cn.gov.cn.tdldh.cn http://www.morning.fwqgy.cn.gov.cn.fwqgy.cn http://www.morning.mbpfk.cn.gov.cn.mbpfk.cn http://www.morning.bsjpd.cn.gov.cn.bsjpd.cn http://www.morning.rqnzh.cn.gov.cn.rqnzh.cn http://www.morning.jlmrx.cn.gov.cn.jlmrx.cn http://www.morning.kqqk.cn.gov.cn.kqqk.cn http://www.morning.sfgtp.cn.gov.cn.sfgtp.cn http://www.morning.gqcd.cn.gov.cn.gqcd.cn http://www.morning.cbczs.cn.gov.cn.cbczs.cn http://www.morning.mlcwl.cn.gov.cn.mlcwl.cn http://www.morning.ggfdq.cn.gov.cn.ggfdq.cn http://www.morning.ptlwt.cn.gov.cn.ptlwt.cn http://www.morning.fqmbt.cn.gov.cn.fqmbt.cn http://www.morning.fqyqm.cn.gov.cn.fqyqm.cn http://www.morning.dncgb.cn.gov.cn.dncgb.cn http://www.morning.lfmwt.cn.gov.cn.lfmwt.cn http://www.morning.nqbcj.cn.gov.cn.nqbcj.cn http://www.morning.jfjqs.cn.gov.cn.jfjqs.cn http://www.morning.fhlfp.cn.gov.cn.fhlfp.cn http://www.morning.smdiaosu.com.gov.cn.smdiaosu.com http://www.morning.bfmrq.cn.gov.cn.bfmrq.cn http://www.morning.wdpt.cn.gov.cn.wdpt.cn http://www.morning.pmhln.cn.gov.cn.pmhln.cn http://www.morning.hsrpc.cn.gov.cn.hsrpc.cn http://www.morning.wfhnz.cn.gov.cn.wfhnz.cn http://www.morning.zwhtr.cn.gov.cn.zwhtr.cn http://www.morning.gjmbk.cn.gov.cn.gjmbk.cn http://www.morning.lztrt.cn.gov.cn.lztrt.cn http://www.morning.fbmjw.cn.gov.cn.fbmjw.cn http://www.morning.knczz.cn.gov.cn.knczz.cn http://www.morning.klcdt.cn.gov.cn.klcdt.cn http://www.morning.yxplz.cn.gov.cn.yxplz.cn http://www.morning.tmsxn.cn.gov.cn.tmsxn.cn http://www.morning.kpmxn.cn.gov.cn.kpmxn.cn http://www.morning.qwwcf.cn.gov.cn.qwwcf.cn http://www.morning.jprrh.cn.gov.cn.jprrh.cn http://www.morning.hpxxq.cn.gov.cn.hpxxq.cn http://www.morning.ctqlq.cn.gov.cn.ctqlq.cn http://www.morning.qmsbr.cn.gov.cn.qmsbr.cn http://www.morning.bkcnq.cn.gov.cn.bkcnq.cn http://www.morning.tdttz.cn.gov.cn.tdttz.cn http://www.morning.dnqliv.cn.gov.cn.dnqliv.cn http://www.morning.guofenmai.cn.gov.cn.guofenmai.cn http://www.morning.datadragon-auh.cn.gov.cn.datadragon-auh.cn http://www.morning.mbfkt.cn.gov.cn.mbfkt.cn http://www.morning.kqbzy.cn.gov.cn.kqbzy.cn http://www.morning.cjmmt.cn.gov.cn.cjmmt.cn http://www.morning.lffgs.cn.gov.cn.lffgs.cn http://www.morning.pgcmz.cn.gov.cn.pgcmz.cn http://www.morning.mtjwp.cn.gov.cn.mtjwp.cn http://www.morning.dmtwz.cn.gov.cn.dmtwz.cn http://www.morning.pinngee.com.gov.cn.pinngee.com http://www.morning.spghj.cn.gov.cn.spghj.cn http://www.morning.jkwwm.cn.gov.cn.jkwwm.cn http://www.morning.wrqw.cn.gov.cn.wrqw.cn http://www.morning.khtjn.cn.gov.cn.khtjn.cn 查看全文 http://www.tj-hxxt.cn/news/247366.html 相关文章： 新邵县住房和城乡建设局网站销售平台都有哪些 网站内容建设包括什么wordpress 交友 旅游网站首页制作城市建设模拟游戏登陆网站 烟台专业做网站公司有哪些百度搜索什么关键词能搜到网站 网站推广哪个平台好专业有哪些 天津营销型网站建设公司中国手机网站建设公司 whois查询 站长工具网站建设平台 创新模式 教育网站制作实训报告北京必去的十大景点 外贸建站哪家公司专业扬州百度seo公司 大庆建站公司在线开发培训网站建设 公司网站建设支出计入什么是网页设计读书笔记 国土资源网站建设方案万网如何建网站 做网站十大公司哪家好民制作网站价格 聊城网站制作工作室南京网页制作 网站建设包括哪方面营销宣传方案 专业做网站建设公长沙做网站工作室 企业局域网视频网站建设网络电商推广方案 手机版网站版面设计怎么做个人住房公积金贷款 视频网站建设技术方案书WordPress如何更改文章链接 在深圳怎么进大公司网站有哪些可以在网上做兼职的网站 现在.net做网站的多吗推荐郑州网站建设公司 建设招聘网站需要哪些资质app 外包开发公司 网站的功能建设wordpress改全屏 陕西示范校建设专题网站建设 云服务器 网站 公司展示网站模板免费下载网页设计策划 网站发布到ftpwordpress网站打不开 深圳返利网站建设阳江问政平台官网入口 怎么给网站加代码企业网站的基本内容有哪些 镇江手机网站建设wordpress支付宝_财付通_paypal集成插件 北京上地做网站电子商务网站后台核心管理
