View Source KafkaEx.New.Structs.Offset (kafka_ex v0.15.0)

This module represents Offset value coming from Kafka

Summary

t()

topic()

Builds offset based on list offsets data response

@type partition_response() ::
  KafkaEx.New.Structs.Offset.PartitionOffset.partition_response()

@type t() :: %KafkaEx.New.Structs.Offset{
  partition_offsets: [KafkaEx.New.Structs.Offset.PartitionOffset.t()],
  topic: topic()
}

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

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

Builds offset based on list offsets data response