Struct BuiltTopology 

pub struct BuiltTopology { /* private fields */ }

A built topology: the wire Topology plus the per-subtopology source-topic map that resolves task assignments to concrete topic-partitions.

NOTE: BuiltTopology is not Clone, because the node factories hold Box<dyn Fn…> closures that are not cloneable. The membership client wraps it in an Arc<BuiltTopology>. Use that to share it across tasks.

Implementations

impl BuiltTopology

pub fn to_wire(&self) -> WireTopology

The wire Topology as a serde-serializable view, for golden-frame interop assertions against captured JVM fixtures.

pub fn to_wire_request(&self) -> WireTopology

The byte-exact KIP-1071 StreamsGroupHeartbeat Topology.

The membership client sends this value when it joins the streams group, and an embedder that runs its own membership sends the same value.

pub fn subtopology_ids(&self) -> Vec<String>

The subtopology ids, in the order the wire Topology lists them.

Each id names one task per source partition, so an embedder wires one EmbeddedTask per (subtopology, partition).

pub fn repartition_topics(&self) -> Vec<String>

The internal repartition topics, sorted and without duplicates.

A subtopology writes a repartition topic through a sink, and another subtopology reads it as a source. The broker creates these topics when the group joins, so an embedder that plays the broker creates them too.

pub fn changelog_topics(&self) -> &[(String, String)]

Every logged store and its changelog topic, as (store, topic) pairs in ascending store order.

The topic is the REUSE_KTABLE_SOURCE_TOPICS source topic when the optimizer reuses one, else <application_id>-<store>-changelog. A store with logging off has no pair, and neither does a global store.

pub fn global_store_topics(&self) -> HashMap<String, String>

The global store name -> source topic map for each GlobalKTable.

The shared global-store manager reads this so the global consumer knows which topic feeds each store, and an embedder reads it to know which topics to replay into EmbeddedTask::apply_global. The map is invisible in the wire output.

pub fn source_topics_for(&self, subtopology_id: &str) -> &[String]

The external and repartition source topics that a subtopology’s tasks read.

pub fn application_id(&self) -> &str

The application id, which sets the internal-topic names.

pub fn list_source_topics(&self) -> Vec<String>

Topics that are sources in this topology, for the test driver and the repartition loopback.

pub fn list_sink_topics(&self) -> Vec<String>

Topics that sinks in this topology write to.

Trait Implementations

impl Debug for BuiltTopology

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.