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

Clear messages acked/expected acks on buffered producer

Browse Source
This commit is contained in:
Matias Fontanini
2017-07-11 10:17:58 -07:00
parent b7a0dce710
commit 2340046544
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -224,6 +224,8 @@ template <typename BufferType>
void BufferedProducer<BufferType>::clear() { void BufferedProducer<BufferType>::clear() {
QueueType tmp; QueueType tmp;
std::swap(tmp, messages_); std::swap(tmp, messages_);
expected_acks_ = 0;
messages_acked_ = 0;
} }
template <typename BufferType> template <typename BufferType>