View Source Runbox.Scenario.InputTopic (runbox v21.2.0)

Struct representing mapping of logical topics (defined in scenarios) to physical topics (actual kafka topics).

Summary

Types

@type t() :: %Runbox.Scenario.InputTopic{
  logical_topic: String.t(),
  physical_topic: String.t(),
  resolve_physical_topic?: term()
}