Class DocumentDeleteEmitter

java.lang.Object

ai.pipestream.connector.intake.pipedoc.streaming.DocumentDeleteEmitter

@ApplicationScoped
public class DocumentDeleteEmitter
extends Object

Publishes the intake layer's broadcast DocumentDeleted signal to Kafka. A logical-document delete (a connector detected the source row/file is gone) is emitted ONCE; interested parties (repo-service, search index, …) each consume it and handle their own delete.

Keyed by a deterministic UUID derived from doc_id so redeliveries land on the same partition and the apicurio protobuf serializer's UUID-key contract is satisfied.

Constructor Summary

Constructors

Constructor	Description
DocumentDeleteEmitter()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	publish(ai.pipestream.repository.v1.DocumentDeleted event)	Publish one delete broadcast.

Methods inherited from class Object

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

Constructor Details

DocumentDeleteEmitter

public DocumentDeleteEmitter()

Method Details

publish

public io.smallrye.mutiny.Uni<Void> publish(ai.pipestream.repository.v1.DocumentDeleted event)

Publish one delete broadcast. The returned Uni completes when the broker acks the record, so callers can confirm the message is out before acknowledging the delete to the connector.

Stamps sent_at (if unset) so consumers can apply the out-of-order / stale-delete guard — a delete whose sent_at predates a doc's latest re-index is skipped, so a late delete can't nuke a re-created doc.