From 8b431c5421b37ce69cbc6218453da8fbb5185586 Mon Sep 17 00:00:00 2001
From: accelerated <>
Date: Fri, 14 Dec 2018 16:32:33 -0500
Subject: [PATCH] changed rbegin to begin

---
 include/cppkafka/utils/buffered_producer.h | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
index 69f7434..55063f2 100644
--- a/include/cppkafka/utils/buffered_producer.h
+++ b/include/cppkafka/utils/buffered_producer.h
@@ -585,7 +585,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
         // Re-enqueue remaining messages in original order
         if (!flush_queue.empty()) {
             std::lock_guard<std::mutex> lock(mutex_);
-            messages_.insert(messages_.begin(), std::make_move_iterator(flush_queue.rbegin()), std::make_move_iterator(flush_queue.rend()))
+            messages_.insert(messages_.begin(), std::make_move_iterator(flush_queue.begin()), std::make_move_iterator(flush_queue.end()));
         }
     }
     else {