Packages

kafka_ex

0.15.0-dev.1
1.1.1 1.1.0 1.0.2 1.0.1 1.0.0 1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1 0.15.0 0.15.0-dev.1 0.14.0 0.14.0-rc.1 0.13.0 0.12.1 0.11.0 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.0 0.0.2 0.0.1

Elixir client for Apache Kafka with automatic API version negotiation, SASL authentication (PLAIN, SCRAM, OAuth, MSK IAM), consumer groups, compression, and telemetry support.

HexDocs

Current section

Files

Jump to
Readme
36 Versions
1 Dependency
Dependants
Files
Activity
kafka_ex lib kafka_ex supervisor.ex
Raw

lib/kafka_ex/supervisor.ex 

defmodule KafkaEx.Supervisor do

  @moduledoc false



  use DynamicSupervisor



  def start_link(max_restarts, max_seconds) do

    {:ok, pid} =

      DynamicSupervisor.start_link(

        __MODULE__,

        [max_restarts, max_seconds],

        name: __MODULE__

      )



    {:ok, pid}

  end



  def start_child(impl, args) when is_atom(impl) and is_list(args) do

    spec = %{id: impl, start: {impl, :start_link, args}}

    DynamicSupervisor.start_child(__MODULE__, spec)

  end



  def stop_child(child) do

    DynamicSupervisor.terminate_child(__MODULE__, child)

  end



  def init([max_restarts, max_seconds]) do

    DynamicSupervisor.init(

      strategy: :one_for_one,

      max_restarts: max_restarts,

      max_seconds: max_seconds

    )

  end

end