以下说明和命令中所使用 topic 的名称结构如下：

Pulsar中的非分区主题必须显式创建。 在创建一个新的非分区主题时，您必须提供为该分区提供一个分区名称。

pulsar-admin

您可以使用create命令来创建非分区主题，并指定分区名称作为一个参数。 Here’s an example:

$ bin/pulsar-admin topics create \

Note

如果已经存在一个同名的分区主题，例如’xyz-topic’，并且其分区数量比要创建的主题名称中包含的数字要大，在本例中为11（分区索引从0开始），那么只有要创建的非分区主题的名称中包含由’-partition-‘及紧接着的一个数字组成的后缀时，例如，’xyz-topic-partition-10’，创建非分区主题才是允许的。 否则，该主题的创建将会失败。

REST API

Java

admin.topics().createNonPartitionedTopic(topicName);

pulsar-admin

要删除非分区主题，可以使用 删除 命令，并按名称指定主题：

REST API

DELETE /admin/v2/persistent/:tenant/:namespace/:topic

Java

admin.topics().delete(persistentTopic);

pulsar-admin

$ pulsar-admin topics list tenant/namespace
persistent://tenant/namespace/topic1

REST API

GET /admin/v2/persistent/:tenant/:namespace

Java

It shows current statistics of a given topic. Here’s an example payload:

The following stats are available:

pulsar-admin

The stats for the topic and its connected producers and consumers can be fetched by using the command, specifying the topic by name:

$ pulsar-admin topics stats \
  persistent://test-tenant/namespace/topic \
  --get-precise-backlog

REST API

Java