Package-level declarations

Types

Link copied to clipboard

The subscriptions of one node that read another context's published topic: the runtime of a log's subscriptions over the topic instead, so they keep the semantics of the log's (a shared tail per partition, lanes per aggregate, a checkpoint per subscription and partition at the contiguous low watermark, parking in the ledger), with no Kafka consumer group: