Metadata class.
Holds all metadaata of brokers, streams & partitions.
Liftbridge client instance.
MetadataResponse
gRPC object.
Returns the cluster metadata.
Metadata.
Returns the broker address for the given stream partition.
Stream.
Stream partition.
Broker address.
Returns a map containing stream names and the number of partitions for the stream. This does not match on wildcard subjects, e.g. "foo.*".
Subject to fetch partitions count for.
total partitions for the subject.
Indicates if the Metadata has info for at least one stream with the given subject.
Subject to check metadata for.
true
if metadata was found for subject, or false
otherwise.
Fetches the latest cluster metadata, including stream and broker information.
Metadata.
Liftbridge stream & partition metadata.
Includes useful methods to fetch/refresh Liftbridge metadata and convert them into usable JSON objects.