diff --git a/.env b/.env
index fce0291..51c314e 100644
--- a/.env
+++ b/.env
@@ -13,7 +13,7 @@ MQTT_PORT=1883
 MQTT_USERNAME=meshdev
 MQTT_PASSWORD=large4cats
 MQTT_KEEPALIVE=60
-MQTT_TOPIC='msh/#'
+MQTT_TOPIC='msh/EU_868/#,msh/US/#'
 MQTT_IS_TLS=false
 
 # MQTT protocol version (default: MQTTv5) the public MQTT server supports MQTTv311
diff --git a/main.py b/main.py
index 9770f80..d090783 100644
--- a/main.py
+++ b/main.py
@@ -30,7 +30,9 @@ def release_connection(conn):
 
 def handle_connect(client, userdata, flags, reason_code, properties):
     print(f"Connected with result code {reason_code}")
-    client.subscribe(os.getenv('MQTT_TOPIC', 'msh/israel/#'))
+    topics = os.getenv('MQTT_TOPIC', 'msh/israel/#').split(',')
+    topics_tuples = [(topic, 0) for topic in topics]
+    client.subscribe(topics_tuples)
 
 
 def update_node_status(node_number, status):