[OMON-406] Increase Kafka consumer batch size to 100 (#314)

awegrzyn · web-flow · commit 0d4d2d238732 · 2023-02-13T10:31:25.000+01:00
diff --git 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
@@ -54,7 +54,7 @@ KafkaConsumer::KafkaConsumer(const std::string& url, const std::vector<std::stri
 std::vector<std::pair<std::string, std::string>> KafkaConsumer::pull()
 {
   std::vector<std::pair<std::string, std::string>> received;
-  size_t batch_size = 10;
+  size_t batch_size = 100;
   int remaining_timeout = 1000;
   auto start = std::chrono::high_resolution_clock::now();
 

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ endif()`
`31`	`31`
`32`	`32`	`# Define project`
`33`	`33`	`project(Monitoring`
`34`		`- VERSION 3.15.0`
	`34`	`+ VERSION 3.15.2`
`35`	`35`	`DESCRIPTION "O2 Monitoring library"`
`36`	`36`	`LANGUAGES CXX`
`37`	`37`	`)`
Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ KafkaConsumer::KafkaConsumer(const std::string& url, const std::vector<std::stri`
`54`	`54`	`std::vector<std::pair<std::string, std::string>> KafkaConsumer::pull()`
`55`	`55`	`{`
`56`	`56`	`std::vector<std::pair<std::string, std::string>> received;`
`57`		`- size_t batch_size = 10;`
	`57`	`+ size_t batch_size = 100;`
`58`	`58`	`int remaining_timeout = 1000;`
`59`	`59`	`auto start = std::chrono::high_resolution_clock::now();`
`60`	`60`