Pulsar Administration

Pulsar Admin Client

在 Pulsar 管理方面，Spring Boot 自动配置提供了一个 `PulsarAdministration`用于管理 Pulsar 集群。该管理实现在称为 `PulsarAdminOperations`的接口，并提供 {javadocs}/org/springframework/pulsar/core/PulsarAdminOperations.html[一个 `createOrModify`方法] 通过其契约处理主题管理。

当你使用 Pulsar Spring Boot starter 时，你获得了自动配置的 PulsarAdministration。

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

有许多应用程序属性可用于配置客户端。请参阅 {spring-boot-pulsar-config-props}[spring.pulsar.admin.*] 应用程序属性。

Authentication

在访问需要身份验证的 Pulsar 集群时，管理员客户端需要与常规 Pulsar 客户端相同的安全配置。您可以使用上述 security configuration 替换 spring.pulsar.client 为 spring.pulsar.admin。

Automatic Topic Creation

在初始化时，PulsarAdministration 会检查应用程序上下文中是否有任何 PulsarTopic bean。对于所有此类 bean，PulsarAdministration 将创建相应的主题或（在必要时）修改分区数。

以下示例演示了如何添加 PulsarTopic bean 以便让 PulsarAdministration 为你自动创建主题：

@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();
}