Package ai.pipestream.registration.topics

Class ModuleTopicProvisioner

java.lang.Object

ai.pipestream.registration.topics.ModuleTopicProvisioner

@ApplicationScoped
public class ModuleTopicProvisioner
extends Object

Creates the per-service module-work Kafka topic at module-registration time. One topic per module service: pipestream.module.<moduleName> — no cluster/graph/node (routing identity rides the PipeStream). Single-owner by construction (registration runs in platform-registration-service), idempotent, and created with explicit partitions (NOT broker-default auto-create).

Mirrors the engine's KafkaTopicRegistrar.ensureProcessingTopic idempotent pattern (listTopics → skip if present → createTopics). The blocking AdminClient work runs on the Mutiny worker pool so it composes concurrently with the Apicurio schema-registration unis without blocking the Vert.x event loop. Topic-ensure failure is isolated by the caller — module registration must not fail because Kafka hiccuped.

Constructor Summary

Constructors

Constructor	Description
ModuleTopicProvisioner()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	ensureModuleTopic(String moduleName)	Idempotently ensure pipestream.module.<moduleName> exists, off the event loop.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ModuleTopicProvisioner

public ModuleTopicProvisioner()

Method Details

ensureModuleTopic

public io.smallrye.mutiny.Uni<Void> ensureModuleTopic(String moduleName)

Idempotently ensure pipestream.module.<moduleName> exists, off the event loop. Completes normally whether the topic was created or already existed.