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