Fix set_leader_epoch (#4267)

'leader_epoch_' variable is assigned to itself. Co-authored-by: Pave Pimenov <pavel.pimenov@gmail.com>
confluentinc · Apr 24, 2023 · ffb8cd1 · ffb8cd1
1 parent 3fa4f4f
commit ffb8cd1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -14,6 +14,8 @@ librdkafka v2.1.1 is a maintenance release:
    pkg-config `Requires.private` field (@FantasqueX, @stertingen, #4180).
  * Fixes certain cases where polling would not keep the consumer
    in the group or make it rejoin it (#4256).
+ * Fix to the C++ set_leader_epoch method of TopicPartitionImpl,
+   that wasn't storing the passed value (@pavel-pimenov, #4267).
 
 ## Fixes
 

diff --git a/src-cpp/rdkafkacpp_int.h b/src-cpp/rdkafkacpp_int.h
@@ -1289,7 +1289,7 @@ class TopicPartitionImpl : public TopicPartition {
   }
 
   void set_leader_epoch(int32_t leader_epoch) {
-    leader_epoch_ = leader_epoch_;
+    leader_epoch_ = leader_epoch;
   }
 
   std::ostream &operator<<(std::ostream &ostrm) const {