defmodule Runbox.Scenario.InputTopic do @moduledoc """ Struct representing mapping of logical topics (defined in scenarios) to physical topics (actual kafka topics). """ alias __MODULE__ defstruct physical_topic: "default", resolve_physical_topic?: true, logical_topic: "default" @type t() :: %InputTopic{ physical_topic: String.t(), logical_topic: String.t() } end