Packages

kafka_ex

0.15.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
1 Dependency
Dependants
Files
Activity
kafka_ex lib kafka_ex new structs offset.ex
Raw

lib/kafka_ex/new/structs/offset.ex 

defmodule KafkaEx.New.Structs.Offset do

  @moduledoc """

  This module represents Offset value coming from Kafka

  """

  defstruct [:topic, :partition_offsets]



  alias KafkaEx.New.Structs.Offset.PartitionOffset



  @type topic :: KafkaEx.Types.topic()

  @type partition_response :: PartitionOffset.partition_response()



  @type t :: %__MODULE__{

          topic: topic(),

          partition_offsets: [PartitionOffset.t()]

        }



  @doc """

  Builds offset based on list offsets data response

  """

  @spec from_list_offset(topic, [partition_response]) :: __MODULE__.t()

  def from_list_offset(topic, partition_responses) do

    %__MODULE__{

      topic: topic,

      partition_offsets: Enum.map(partition_responses, &PartitionOffset.build(&1))

    }

  end

end