java，apache脉冲星主题分区

Question

如果我有一个名为var test = "test"的主题，并创建了一个bean：

@Bean(name = "test")
public Producer<Test> testProducer(PulsarClient pulsarClient){
    return pulsarClient.newProducer()
            .topic(test)
            .create();
}

这个主题是我想要划分的，怎么创建的？

Answer 1

要创建带有分区的主题，可以为Pulsar Broker配置以下设置(如果您依赖自动主题创建)

allowAutoTopicCreationType = partitioned
defaultNumPartitions = <N>

另外，您也可以使用脉冲星管理和使用createPartitionedTopic https://github.com/apache/pulsar/blob/a165bda1d03e370f5efe1173134fb94e12b584b5/pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java#L473-L475。

但是，一旦创建了一个主题(我假设它是非分区的)，那么就没有办法将其分区。必须在主题创建时对其进行分区。