scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 11:07:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added wait_for_acks(0) when calling async_flush

Browse Source
This commit is contained in:
accelerated
2019-02-21 15:21:16 -05:00
parent 5bfc047263
commit ace18d5d7b
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
include/cppkafka/utils/buffered_producer.h
View File

@@ -221,7 +221,8 @@ public:
/** /**
* \brief Flushes all buffered messages and returns immediately. * \brief Flushes all buffered messages and returns immediately.
* *
* Similar to flush, it will send all messages but will not wait for acks to complete. * Similar to flush, it will send all messages but will not wait for acks to complete. However the underlying
* producer will still be flushed.
*/ */
void async_flush(); void async_flush();
@@ -641,6 +642,7 @@ void BufferedProducer<BufferType, Allocator>::async_flush() {
}; };
queue_flusher(retry_messages_, retry_mutex_); queue_flusher(retry_messages_, retry_mutex_);
queue_flusher(messages_, mutex_); queue_flusher(messages_, mutex_);
wait_for_acks(std::chrono::milliseconds(0)); //flush the producer but don't wait
} }
template <typename BufferType, typename Allocator> template <typename BufferType, typename Allocator>