From 6877c4be03d2bd99ff7b72aa9cd9190270f0e181 Mon Sep 17 00:00:00 2001
From: Matias Fontanini <matias.fontanini@gmail.com>
Date: Wed, 15 Jun 2016 07:32:22 -0700
Subject: [PATCH] Add enum for TopicPartition offsets

---
 include/cppkafka/topic_partition.h  | 10 ++++++++++
 tests/topic_partition_list_test.cpp |  1 +
 2 files changed, 11 insertions(+)

diff --git a/include/cppkafka/topic_partition.h b/include/cppkafka/topic_partition.h
index 2664c84..e3b23bb 100644
--- a/include/cppkafka/topic_partition.h
+++ b/include/cppkafka/topic_partition.h
@@ -40,6 +40,16 @@ namespace cppkafka {
  */
 class TopicPartition {
 public:
+    /**
+     * Special offsets enum
+     */
+    enum Offset {
+        OFFSET_BEGINNING = -2,
+        OFFSET_END = -1,
+        OFFSET_STORED = -1000,
+        OFFSET_INVALID = -1001
+    };
+
     /**
      * Default constructs a topic/partition
      */
diff --git a/tests/topic_partition_list_test.cpp b/tests/topic_partition_list_test.cpp
index 82eee62..b801e7b 100644
--- a/tests/topic_partition_list_test.cpp
+++ b/tests/topic_partition_list_test.cpp
@@ -13,6 +13,7 @@ TEST_F(TopicPartitionListTest, Conversion) {
     TopicPartitionList list1;
     list1.push_back("foo");
     list1.push_back({ "bar", 2 });
+    list1.push_back({ "asd", 2, TopicPartition::OFFSET_BEGINNING });
 
     TopicPartitionList list2 = convert(convert(list1));