fix: added flush() for proper shutdown

i-chvets · i-chvets · commit 280ae2418202 · 2024-06-18T10:46:42.000-04:00
https://telecominfraproject.atlassian.net/browse/WIFI-13597 Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp
@@ -123,6 +123,7 @@ namespace OpenWifi {
 			}
 			Note = Queue_.waitDequeueNotification();
 		}
+		Producer.flush();
 		poco_information(Logger_, "Stopped...");
 	}
 
@@ -328,4 +329,4 @@ namespace OpenWifi {
 											   partitions.front().get_partition()));
 	}
 
-} // namespace OpenWifi
+} // namespace OpenWifi

Original file line number	Diff line number	Diff line change
`@@ -123,6 +123,7 @@ namespace OpenWifi {`
`123`	`123`	`}`
`124`	`124`	`Note = Queue_.waitDequeueNotification();`
`125`	`125`	`}`
	`126`	`+ Producer.flush();`
`126`	`127`	`poco_information(Logger_, "Stopped...");`
`127`	`128`	`}`
`128`	`129`
`@@ -328,4 +329,4 @@ namespace OpenWifi {`
`328`	`329`	`partitions.front().get_partition()));`
`329`	`330`	`}`
`330`	`331`
`331`		`-} // namespace OpenWifi`
	`332`	`+} // namespace OpenWifi`