lib/runbox/scenario/input_topic.ex

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