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

This module represents Offset value for a specific partition

Summary

Types

error_code()

offset()

partition()

partition_response()

t()

timestamp()

Functions

build(map)

For older API versions, kafka is not returning offset timestamp. For backward compatibility with kafka_ex, we will replace this nil values with -1

Types

error_code()

@type error_code() :: KafkaEx.Types.error_code() | atom()

offset()

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

partition()

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

partition_response()

@type partition_response() :: %{
  :partition => partition(),
  :error_code => error_code(),
  :offset => offset(),
  optional(:timestamp) => timestamp()
}

t()

@type t() :: %KafkaEx.New.Structs.Offset.PartitionOffset{
  error_code: error_code(),
  offset: offset(),
  partition: partition(),
  timestamp: timestamp()
}

timestamp()

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

Functions

build(map)

@spec build(partition_response()) :: t()

For older API versions, kafka is not returning offset timestamp. For backward compatibility with kafka_ex, we will replace this nil values with -1