userver: userver/kafka/offset_range.hpp Source File
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages Concepts
offset_range.hpp
1#pragma once
2
3#include <cstdint>
4
5USERVER_NAMESPACE_BEGIN
6
7namespace kafka {
8
9/// @brief Represents the range of offsets for certain topic.
10struct OffsetRange final {
11 /// @brief The low watermark offset. It indicates the earliest available offset in Kafka.
12 /// @note low offset is guaranteed to be committed. Max value is std::int64_t::max() according to Kafka protocol
13 /// document.
14 std::uint64_t low{};
15
16 /// @brief The high watermark offset. It indicates the next offset that will be written in Kafka.
17 /// @note high offset is not required to be committed yet. Max value is std::int64_t::max() according to Kafka
18 /// protocol document.
19 std::uint64_t high{};
20};
21
22} // namespace kafka
23
24USERVER_NAMESPACE_END