Merge pull request #3763 from NicholasTurner23/update/Kafka-implement…

…ations

Update/kafka implementations

src/workflows/airqo_etl_utils/message_broker_utils.py

@@ -35,7 +35,7 @@ def __init__(self):
         # Note: This should be updated in case the number of partions used changes.
         self.partition_loads = {int(p): 0 for p in self.__partitions}
         self.config = {
-            "bootstrap.servers": "35.187.179.27:30200,34.79.78.204:30200,34.78.90.92:30200",
+            "bootstrap.servers": self.__bootstrap_servers,
             "metadata.max.age.ms": 60000,
         }