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

Merge pull request #40 from arvidn/poll-batch-performance

Browse Source 
improve performance of Consumer::poll_batch()
This commit is contained in:
Matias Fontanini
2018-03-17 15:41:21 -07:00
committed by GitHub
parent deff8b1ff3 98b9839ff9
commit 675954ef75
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/consumer.cpp
View File

@@ -214,13 +214,15 @@ vector<Message> Consumer::poll_batch(size_t max_batch_size, milliseconds timeout
raw_messages.size()); raw_messages.size());
if (result == -1) { if (result == -1) {
check_error(rd_kafka_last_error()); check_error(rd_kafka_last_error());
// on the off-chance that check_error() does not throw an error
result = 0;
} }
vector<Message> output; vector<Message> output;
raw_messages.resize(result);
output.reserve(result);
for (const auto ptr : raw_messages) { for (const auto ptr : raw_messages) {
if (ptr) {
output.emplace_back(ptr); output.emplace_back(ptr);
} }
}
return output; return output;
} }