Packages

kafka_ex

0.9.0
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
0 Dependencies
Dependants
Files
Activity
kafka_ex lib kafka_ex exceptions.ex
Raw

lib/kafka_ex/exceptions.ex 

defmodule KafkaEx.ConsumerGroupRequiredError do

  defexception [:message]



  def exception(%{__struct__: struct}) do

    message =

      "KafkaEx requests of type #{struct} " <>

        "require that the worker is configured for a consumer group."



    %__MODULE__{message: message}

  end



  def exception(action) when is_binary(action) do

    message =

      "KafkaEx #{action} requires that the worker is configured " <>

        "for a consumer group."



    %__MODULE__{message: message}

  end

end



defmodule KafkaEx.InvalidConsumerGroupError do

  defexception [:message]



  def exception(consumer_group) do

    message = "Invalid consumer group: #{inspect(consumer_group)}"

    %__MODULE__{message: message}

  end

end