1. Pulsar 管理客户端

在 Pulsar 管理端，Spring Boot 自动配置提供了用于管理 Pulsar 集群的功能。 管理实现一个名为的接口，并提供 createOrModify 方法，以通过其协定处理主题管理。PulsarAdministrationPulsarAdminOperations

当您使用 Pulsar Spring Boot 启动器时，您将获得自动配置。PulsarAdministration

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

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

1.1. 身份验证

当访问需要认证的 Pulsar 集群时，管理客户端需要与常规 Pulsar 客户端相同的安全配置。 您可以使用上述安全配置，将 替换为 。spring.pulsar.clientspring.pulsar.admin

2. 自动创建主题

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

以下示例演示如何添加 Bean 以允许自动创建主题：PulsarTopicPulsarAdministration

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