View Source KafkaEx.Messages.Offset (kafka_ex v1.0.0-rc.1)

This module represents Offset value coming from Kafka

Summary

t()

topic()

Builds offset based on list offsets data response

@type partition_response() ::
  KafkaEx.Messages.Offset.PartitionOffset.partition_response()

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

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

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

Builds offset based on list offsets data response