1.3 Quick Start中 Step 3: Create a topic官网剖析(博主推荐)

本文涉及的产品
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介:

 一切来源于官网

http://kafka.apache.org/documentation/

 

 

 

 

Step 3: Create a topic

Step 3: 创建一个主题(topic)

 

  Let's create a topic named "test" with a single partition and only one replica:

创建一个名为“test”的Topic,只有一个分区和一个备份:
 
> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

  We can now see that topic if we run the list topic command:

创建好之后,可以通过运行以下命令,查看已创建的topic信息:
> bin/kafka-topics.sh --list --zookeeper localhost:2181
test

  Alternatively, instead of manually creating topics you can also configure your brokers to auto-create topics when a non-existent topic is published to.

或者,除了手工创建topic外,你也可以配置你的broker,当发布一个不存在的topic时自动创建topic。

 

 

 

  

 

  其实,这个很简单,比如--create就是创建,--list是查看。当然,不能局限于官网,大家要灵活多变,官网只是个参考和引子。

--topic test  名字为test的topic
--partitions 1   分区数为1
--replication-factor 1    复制因子是1(即每个分区在集群中有1份数据)
--zookeeper localhost:2181  这个不多说,太简单

 

 

   比如,我们一般写

bin/kafka-topics.sh --create --zookeeper master:2181 --replication-factor 3 --partitions 10 --topic t-behavior

bin/kafka-topics.sh --create --zookeeper hadoop1:2181 --replication-factor 3 --partitions 10 --topic t-behavior
说明:

--replication-factor 3     指定了复制因子3,即每个分区在集群中有3份数据

--partitions  10          指定topic的分区数10
--topic t-behavior       指定创建名为t-behavior的topic

 

 

 

 同时,查看topic详情

bin/kafka-topics.sh --zookeeper txy001:2181 --topic t-behavior --describe
复制代码
打印如下:
Topic:t-behavior  PartitionCount:10       ReplicationFactor:3     Configs:
        Topic: t-behavior Partition: 0    Leader: 1       Replicas: 1,2,0 Isr: 0,1,2
        Topic: t-behavior Partition: 1    Leader: 2       Replicas: 2,0,1 Isr: 0,1,2
        Topic: t-behavior Partition: 2    Leader: 0       Replicas: 0,1,2 Isr: 0,1,2
        Topic: t-behavior Partition: 3    Leader: 1       Replicas: 1,0,2 Isr: 0,1,2
        Topic: t-behavior Partition: 4    Leader: 2       Replicas: 2,1,0 Isr: 0,1,2
        Topic: t-behavior Partition: 5    Leader: 0       Replicas: 0,2,1 Isr: 0,1,2
        Topic: t-behavior Partition: 6    Leader: 1       Replicas: 1,2,0 Isr: 0,1,2
        Topic: t-behavior Partition: 7    Leader: 2       Replicas: 2,0,1 Isr: 0,1,2
        Topic: t-behavior Partition: 8    Leader: 0       Replicas: 0,1,2 Isr: 0,1,2
        Topic: t-behavior Partition: 9    Leader: 1       Replicas: 1,0,2 Isr: 0,1,2
说明;
ReplicationFactor 表示复制因子,即每个分区有几份数据
Leader 分区的主在那个broker上
Replicas 表示分区数据分布在哪些broker上
Isr 表示可立即作为分区的主的broker,即标识3分数据已经保持一致了。
复制代码

 

 


本文转自大数据躺过的坑博客园博客,原文链接:http://www.cnblogs.com/zlslch/p/6766890.html,如需转载请自行联系原作者

相关文章
|
4月前
|
SQL 分布式计算 DataWorks
DataWorks操作报错合集之在使用函数holiday_date遇到报错: “Perhaps you forgot to add it to using list when create funciton.,是什么原因
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
5月前
|
DataWorks 关系型数据库 MySQL
DataWorks操作报错合集之遇到报错:column 'street_cd' type 'void' is not allowed.,如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
6月前
|
消息中间件 关系型数据库 MySQL
实时计算 Flink版操作报错合集之报错:“Data row is smaller than a column index”如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
233 2
|
6月前
|
运维 Kubernetes Devops
云效产品使用报错问题之flow step publish 新的镜像提示: step sign 已被占用。如何解决
本合集将整理呈现用户在使用过程中遇到的报错及其对应的解决办法,包括但不限于账户权限设置错误、项目配置不正确、代码提交冲突、构建任务执行失败、测试环境异常、需求流转阻塞等问题。阿里云云效是一站式企业级研发协同和DevOps平台,为企业提供从需求规划、开发、测试、发布到运维、运营的全流程端到端服务和工具支撑,致力于提升企业的研发效能和创新能力。
|
人工智能 达摩院 API
阿里云灵积模型服务Quick Start
DashScope灵积模型服务以模型为中心,致力于面向AI应用开发者提供品类丰富、数量众多的模型选择,并为其提供开箱即用、能力卓越、成本经济的模型服务API。DashScope灵积模型服务依托达摩院等机构的优质模型,在阿里云基础设施之上构建。灵积服务4.11号刚刚开通公测,目前提供Paraformer语音识别API能力,后续通义千问也将通过该服务对外提供API能力。本文演示如何快速通过Python SDK接入服务。
70961 0
阿里云灵积模型服务Quick Start
|
人工智能 开发者 Docker
ModelScope使用Quick Start
ModelScope是阿里巴巴打造下一代开源的模型即服务共享平台,为泛AI开发者提供灵活、易用、低成本的一站式模型服务产品,让模型应用更简单!本文通过Docker Image的方式演示服务的快速使用。
2652 0
ModelScope使用Quick Start
|
机器人 测试技术 数据库
RobotFramework 官方demo Quick Start Guide rst配置文件分析
RobotFramework 官方demo Quick Start Guide rst配置文件分析
148 0
|
移动开发 机器人 数据安全/隐私保护
RobotFramework RobotFramework官方demo Quick Start Guide浅析
RobotFramework RobotFramework官方demo Quick Start Guide浅析
108 0
|
机器学习/深度学习 存储 JSON
PAI EAS服务使用eascmd客户端管理 Quick Start
为实现一站式算法应用,PAI针对在线推理场景提供了在线预测服务PAI-EAS(Elastic Algorithm Service),支持基于异构硬件(CPU和GPU)的模型加载和数据请求的实时响应。通过PAI-EAS,您可以将模型快速部署为RESTful API,再通过HTTP请求的方式调用该服务。您也可以使用eascmd命令行方式进行部署管理PAI-EAS服务。本文基于已经训练好的线性回归算法实验为您介绍如何使用eascmd客户端上传文件、创建服务、修改服务配置信息的相关命令演示,以供参考。
378 0
PAI EAS服务使用eascmd客户端管理 Quick Start
《Drools6.4 中文文档》第18章18.2 Quick Start(快速开始)
《Drools6.4 中文文档》第18章18.2 Quick Start(快速开始)
104 0
《Drools6.4 中文文档》第18章18.2 Quick Start(快速开始)