Add TopicPartition::set_offset

include/cppkafka/topic_partition.h

@@ -107,6 +107,11 @@ public:
      */
     int64_t get_offset() const;
 
+    /**
+     * Sets the offset
+     */
+    void set_offset(int64_t offset);
+
     /**
      * Print to a stream
      */

src/topic_partition.cpp

@@ -73,6 +73,10 @@ int64_t TopicPartition::get_offset() const {
     return offset_;
 }
 
+void TopicPartition::set_offset(int64_t offset) {
+    offset_ = offset;
+}
+
 ostream& operator<<(ostream& output, const TopicPartition& rhs) {
     return output << rhs.get_topic() << "[" << rhs.get_partition() << "]";
 }