Topic管理-华为云

分布式消息服务KAFKA版-修改Topic分区数:方式3：在Kafka客户端上修改

方式3：在Kafka客户端上修改 Kafka客户端版本为2.2以上时，支持通过kafka-topics.sh修改Topic分区数。已开启SASL的实例，“allow.everyone.if.no.acl.found”设置为“false”时，无法通过客户端修改Topic分区数。未开启SASL的Kafka实例，在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令修改Topic分区数。 ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num} 已开启SASL的Kafka实例，通过以下步骤修改Topic分区数。（可选）如果已经设置了SSL证书配置，请跳过此步骤。否则请执行以下操作。在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加SSL证书配置。在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令修改Topic分区数。 ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num} --command-config ./config/ssl-user-config.properties

分布式消息服务KAFKA版 Topic管理

分布式消息服务ROCKETMQ版-查询主题列表:响应参数

响应参数状态码： 200 表3 响应Body参数参数参数类型描述 total Integer topic总数。 max Integer 最大可创建topic数量。 remaining Integer 剩余可创建topic数量。 next_offset Integer 下个分页的offset。 previous_offset Integer 上个分页的offset。 topics Array of Topic objects topic列表。表4 Topic 参数参数类型描述 name String topic名称。 total_read_queue_num Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。 message_type String 消息类型（RocketMQ实例5.x版本才包含此参数）。缺省值：all 表5 brokers 参数参数类型描述 broker_name String 代理名称。 read_queue_num Number 读队列个数。 write_queue_num Number 写队列个数。

分布式消息服务ROCKETMQ版 Topic管理

分布式消息服务ROCKETMQ版-查询主题列表:响应示例

响应示例状态码： 200 查询成功。 { "total" : "3,", "max" : "2000,", "remaining" : "1997,", "next_offset" : "-1,", "previous_offset" : "-1,", "topics" : [ { "name" : "topic-1", "total_read_queue_num" : 3, "total_write_queue_num" : 3, "permission" : "all", "brokers" : [ { "broker_name" : "broker-0", "read_queue_num" : 3, "write_queue_num" : 3 } ], "message_type" : "NORMAL" }, { "name" : "topic-2", "total_read_queue_num" : 3, "total_write_queue_num" : 3, "permission" : "all", "brokers" : [ { "broker_name" : "broker-0", "read_queue_num" : 3, "write_queue_num" : 3 } ], "message_type" : "NORMAL" }, { "name" : "topic-3", "total_read_queue_num" : 3, "total_write_queue_num" : 3, "permission" : "all", "brokers" : [ { "broker_name" : "broker-0", "read_queue_num" : 3, "write_queue_num" : 3 } ], "message_type" : "NORMAL" } ] }

分布式消息服务ROCKETMQ版 Topic管理

分布式消息服务ROCKETMQ版-查询主题列表:URI

URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数参数是否必选参数类型描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。表2 Query参数参数是否必选参数类型描述 limit 否 Integer 查询数量，取值范围为1~50。 offset 否 Integer 偏移量，表示从此偏移量开始查询， offset大于等于0。

分布式消息服务ROCKETMQ版 Topic管理

应用与数据集成平台 ROMA Connect-导入导出Topic:前提条件

前提条件导入Topic前，请确保Topic所属的集成应用已创建，否则请提前创建集成应用。导入Topic前，请检查导入Topic的实例中是否存在重名Topic，若存在重名Topic，会导致导入Topic失败。导入Topic前，请确保Topic的配额满足需求。若Topic的描述信息中有换行符时，导出Topic的csv文件中会将换行符转义成“\n”。若使用该csv文件导入Topic，在导入Topic后，需在控制台上手动修改Topic的描述信息，把转义字符“\n”修改成换行符。导入Topic时，导入的文件中最多包含100个Topic，否则将导入Topic失败。请勿使用Excel编辑导出的csv文件，否则会打乱csv文件的内容格式，导致导入失败。若需要编辑导出的文件后导入，请导出xlsx或xls格式进行编辑。

应用与数据集成平台 ROMA Connect Topic管理

云服务器内容精选

Topic管理

7*24

备案

专业服务

退订

建议反馈

售前咨询热线