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

Change logic to reset messages acked count on buffered producer

Browse Source
This commit is contained in:
Matias Fontanini
2017-04-23 14:55:33 -07:00
parent 7ec3252a86
commit 5e84da2458
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -169,7 +169,6 @@ void BufferedProducer<BufferType>::flush() {
template <typename BufferType> template <typename BufferType>
void BufferedProducer<BufferType>::wait_for_acks() { void BufferedProducer<BufferType>::wait_for_acks() {
messages_acked_ = 0;
while (messages_acked_ < expected_acks_) { while (messages_acked_ < expected_acks_) {
try { try {
producer_.flush(); producer_.flush();
@@ -185,6 +184,7 @@ void BufferedProducer<BufferType>::wait_for_acks() {
} }
} }
expected_acks_ = 0; expected_acks_ = 0;
messages_acked_ = 0;
} }
template <typename BufferType> template <typename BufferType>