当前位置: 首页 > news >正文

广州手机网站建设费用人力资源和社会保障部

广州手机网站建设费用,人力资源和社会保障部,seo专员工作容易学吗,做网站找我要服务器密码一、topic命令 下面Windows命令需要把cmd路径切换到bin/windows下。 而Linux命令只需要在控制台切换到bin目录下即可。 下面都以Windows下的操作为例,在Linux下也是一样的。 1.1 查看主题命令的参数 kafka-topics.bat # Windows kafka-topics.sh # Linux输…

一、topic命令

下面Windows命令需要把cmd路径切换到bin/windows下。

Linux命令只需要在控制台切换到bin目录下即可。

下面都以Windows下的操作为例,在Linux下也是一样的。
在这里插入图片描述

1.1 查看主题命令的参数

kafka-topics.bat		# Windows
kafka-topics.sh			# Linux

在这里插入图片描述

输入以上命令就可以看到主题命令可以附加哪些参数来执行,参数有很多,这里归纳几个常用的:

参数说明
–bootstrap-server连接的 Kafka Broker 主机名称和端口号。
–topic操作的 topic 名称。
–create创建主题。
–delete删除主题。
–alter修改主题。
–list查看所有主题。
–describe查看主题详细描述。
–partitions <Integer: # of partitions>设置分区数。
–replication-factor <Integer: replication factor>设置分区副本。
–config <String: name=value>更新系统默认的配置。

1.2 查看当前服务器中的所有 topic

kafka-topics.bat --bootstrap-server localhost:9092 --list

Kafka默认在9092端口上运行

1.3 创建名为test的topic

kafka-topics.bat --bootstrap-server localhost:9092 --create --partitions 1 --replication-factor 1 --topic test
  • --partitions :指定分区数,参数要根据broker数和数据量决定,有几个broker则可以指定几个分区

  • --replication-factor: 指定副本数,也有根据有几个broker来决定

  • --topic :指定topic名字

1.4 查看 test主题的详情

kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test

在这里插入图片描述
这里主要注意后面第二排参数的意义即可。

Topic:test:主体的名称是test

Partition:分区编号是0,代表只有一个分区,编号从0开始

Leader:每个分区多个副本的主节点编号,这个在集群中才会是其它值,这里是单机模式,值等于唯一副本编号

Replicas:副本编号,也是从0开始。

1.5 修改分区数

kafka-topics.bat --bootstrap-server localhost:9092 --alter --topic test --partitions 2

注意:分区数只能增加,不能减少

1.6 再次查看 test主题的详情

kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test

1.7 删除 topic

kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic test

二、生产者命令

下面Windows命令需要把cmd路径切换到bin/windows下。
在这里插入图片描述

2.1 查看生产者命令的参数

kafka-console-producer.bat

常用参数:

参数说明
–bootstrap-server连接的 Kafka Broker 主机名称和端口号。
–topic操作的 topic 名称。

2.2 发送消息

主要就是要说明要连接哪个Kafka服务器或者集群。

kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test

在这里插入图片描述

此时光标处就可以输入数据,输入的数据会放入本机kafka 服务器test这个主题当中。

三、消费者命令

在这里插入图片描述

3.1 查看消费者命令的参数

kafka-console-consuer.bat

常用参数:

参数说明
–bootstrap-server连接的 Kafka Broker 主机名称和端口号。
–topic操作的 topic 名称。

3.2 消费消息

1)消费 first 主题中的数据。

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

2)把主题中所有的数据都读取出来(包括历史数据)

kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic test

四、使用示例

这些示例都基于上面的主题test来进行操作。

4.1 生产者生产一条数据

kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test

在这里插入图片描述

此时输入一个hello数据然后回车,队列中就加入了一条数据。

4.2 创建一个消费者

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

在这里插入图片描述

发现此时并没有消费到刚才的数据。

4.3 生产者再生产一个数据

就是在刚才的光标下继续输入一个数据,再回车即可。
在这里插入图片描述

此时再看消费者,发现消费者已经消费到了Kafka这条数据。

在这里插入图片描述

这时候就发现了一个问题,消费者只能消费消费者出现之后的数据,之前的历史数据则不能直接被消费。

4.4 把主题中所有的数据都读取出来

如果想要读取历史数据,可以选择把主题中的数据全部读取出来。

kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic test

在这里插入图片描述
执行此命令后,再来新的数据,也会被继续消费,就和普通的消费者一样。

http://www.hrbkazy.com/news/24040.html

相关文章:

  • 沧州省建设厅网站一站式海外推广平台
  • 展示网站开发 大概多少钱seo网络推广到底是做什么的
  • 文学网站怎样建设百度不收录网站
  • 手机网站建设系统资源网站优化排名软件
  • 宁波做外贸网站推广免费网站搭建
  • 网站实名制 怎么做google关键词工具
  • php网站开发文档怎么写可以发外链的网站整理
  • 做网站的职位叫什么问题网络营销策略实施的步骤
  • 百度搜不到的网站河南网站建设制作
  • 公司网站彩页怎么做网站快速被百度收录
  • 本科自考有什么专业站长之家seo查询
  • 网站建设开发原代码归属武汉seo报价
  • 永康网站建设公司百度上如何做优化网站
  • 重庆做网站建设公司排名项目推广方式有哪些
  • wordpress无广告视频网站淘宝推广引流方法有哪些
  • 宝山企业做网站怎样推广自己的产品
  • 网站图片一般多大尺寸seo优化与sem推广有什么关系
  • 建站平台 iis如何建立网址
  • 做外贸仿牌网站云南百度公司
  • 没有自己的境外网站怎么做谷歌推广百度竞价推广运营
  • 聊城网站开发公司教育机构在线咨询
  • 腾讯网静态网站建设站内推广方式有哪些
  • 网站 description精准营销系统价值
  • 建设网站注意什么竞价排名点击
  • 公司网站是用什么软件做软文写作发布
  • 美观网站建设物美价廉东莞疫情最新消息今天新增病例
  • 免费教育网站大全 建站百度学术搜索
  • 网站建设购销合同刷赞网站推广ks
  • 网站推广应该坚持( )策略。电商运营推广是做什么的
  • 网站怎么做脚注如何自己建立一个网站