Merge pull request #215 from accelerated/partition

Added method to set the partition

include/cppkafka/topic_partition.h

@@ -106,6 +106,11 @@ public:
      * Gets the offset
      */
     int64_t get_offset() const;
+    
+    /**
+     * @brief Sets the partition
+     */
+    void set_partition(int partition);
 
     /**
      * Sets the offset

src/topic_partition.cpp

@@ -76,6 +76,10 @@ int64_t TopicPartition::get_offset() const {
     return offset_;
 }
 
+void TopicPartition::set_partition(int partition) {
+    partition_ = partition;
+}
+
 void TopicPartition::set_offset(int64_t offset) {
     offset_ = offset;
 }