diff --git a/CMakeLists.txt b/CMakeLists.txt index a0ee74f7..4011992f 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -31,7 +31,7 @@ endif() # Define project project(Monitoring - VERSION 3.15.0 + VERSION 3.15.2 DESCRIPTION "O2 Monitoring library" LANGUAGES CXX ) diff --git a/src/Transports/KafkaConsumer.cxx b/src/Transports/KafkaConsumer.cxx index cce423ec..6b28ec1c 100644 --- a/src/Transports/KafkaConsumer.cxx +++ b/src/Transports/KafkaConsumer.cxx @@ -54,7 +54,7 @@ KafkaConsumer::KafkaConsumer(const std::string& url, const std::vector> KafkaConsumer::pull() { std::vector> received; - size_t batch_size = 10; + size_t batch_size = 100; int remaining_timeout = 1000; auto start = std::chrono::high_resolution_clock::now();