my_supervisor.ex

defmodule MySupervisor do
  @moduledoc """
  Supervisor to manage MyWorker.
  """

  use Supervisor

  def start_link do
    Supervisor.start_link(__MODULE__, [], name: __MODULE__)
  end

  def init(_args) do
    children = [
      worker(MyWorker, [], restart: :transient)
    ]

    supervise(children, strategy: :simple_one_for_one)
  end

  def start_child(%{"topic" => topic}) do
    Supervisor.start_child(__MODULE__, [topic])
  end

end