diff --git a/memphis/memphis.py b/memphis/memphis.py
index 5482ad4..21c872e 100644
--- a/memphis/memphis.py
+++ b/memphis/memphis.py
@@ -466,9 +466,10 @@ async def _single_station_producer(
                 "station_name": station_name,
                 "connection_id": self.connection_id,
                 "producer_type": "application",
-                "req_version": 3,
+                "req_version": 4,
                 "username": self.username,
                 "app_id": app_id,
+                "sdk_lang": "python"
             }
             create_producer_req_bytes = json.dumps(create_producer_req, indent=2).encode(
                 "utf-8"
@@ -713,9 +714,10 @@ async def consumer(
                 "max_msg_deliveries": max_msg_deliveries,
                 "start_consume_from_sequence": start_consume_from_sequence,
                 "last_messages": last_messages,
-                "req_version": 3,
+                "req_version": 4,
                 "username": self.username,
                 "app_id": app_id,
+                "sdk_lang":"python"
             }
 
             create_consumer_req_bytes = json.dumps(create_consumer_req, indent=2).encode(