added missing return

mfontanini · Jan 18, 2019 · 755e9f1 · 755e9f1
1 parent 5a34955
commit 755e9f1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
@@ -708,6 +708,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
         };
         re_enqueuer(retry_flush_queue, retry_messages_, retry_mutex_);
         re_enqueuer(flush_queue, messages_, mutex_);
+        return true;
     }
     else {
         async_flush();