Pulsar 管理

1. Pulsar Admin 客户端

在 Pulsar 管理方面，Spring Boot 自动配置提供了管理 Pulsar 集群的方法。管理实现一个名为 createOrModify 的接口，并提供一个 createOrModify 方法，以通过其 Contract 处理主题管理。PulsarAdministrationPulsarAdminOperationsspring-doc.cn

当您使用 Pulsar Spring Boot Starters时，您将获得自动配置。PulsarAdministrationspring-doc.cn

默认情况下，应用程序会尝试连接到位于的本地 Pulsar 实例。这可以通过在表单中将属性设置为其他值来调整。http://localhost:8080spring.pulsar.admin.service-url(http|https)://<host>:<port>spring-doc.cn

有许多应用程序属性可用于配置客户端。请参阅 spring.pulsar.admin.* 应用程序属性。spring-doc.cn

1.1. 身份验证

访问需要身份验证的 Pulsar 集群时，admin 客户端需要与常规 Pulsar 客户端相同的安全配置。您可以通过将 .spring.pulsar.clientspring.pulsar.adminspring-doc.cn

2. 自动创建主题

在初始化时，检查应用程序上下文中是否有任何 bean。对于所有这些 bean，要么创建相应的主题，要么在必要时修改分区的数量。PulsarAdministrationPulsarTopicPulsarAdministrationspring-doc.cn

以下示例显示了如何添加 bean 以允许自动为您创建主题：PulsarTopicPulsarAdministrationspring-doc.cn

@Bean
PulsarTopic simpleTopic {
	// This will create a non-partitioned topic in the public/default namespace
	return PulsarTopic.builder("simple-topic").build();
}

@Bean
PulsarTopic partitionedTopic {
	// This will create a partitioned topic with 3 partitions in the provided tenant and namespace
	return PulsarTopic.builder("persistent://my-tenant/my-namespace/partitioned-topic", 3).build();
}