Add KAFKA code back in, commented out, in case needed later.

NREL · Dec 12, 2023 · 5eab3a1 · 5eab3a1
1 parent 486e5f5
commit 5eab3a1
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/hercules/emulator.py b/hercules/emulator.py
@@ -56,6 +56,18 @@ def __init__(self, controller, py_sims, input_dict):
 
         # TODO: Store other things
         self.use_dash_frontend = self.helics_config_dict["use_dash_frontend"]
+        # self.KAFKA = self.helics_config_dict["KAFKA"]
+
+        # # TODO Copied direct from control_center.py but not actually ready yet
+        # if self.KAFKA:
+        #     from dav_kafka_python.configuration import Configuration
+        #     from dav_kafka_python.producer import PythonProducer
+        #     # Kafka topic :
+        #     self.topic = self.helics_config_dict["KAFKA_TOPIC"]
+        #     print("KAFKA topic", self.topic)
+        #     config = Configuration(env_path='./.env')
+        #     self.python_producer = PythonProducer(config)
+        #     self.python_producer.connect()
 
         # AMR wind files
         # Grab py sim details