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: