From 77c5d8fd2589875f480023f70a979874ec6faf48 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Wed, 27 Dec 2023 23:32:12 +0200 Subject: [PATCH 1/2] add sdk_lang to create producer & consumer request --- memphis/memphis.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index 5482ad4..559bba0 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": "python3" } 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":"python3" } create_consumer_req_bytes = json.dumps(create_consumer_req, indent=2).encode( From 311a2a58303d759f9ff36f8e81c989bd7ad11d7f Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Thu, 28 Dec 2023 13:10:43 +0200 Subject: [PATCH 2/2] fix --- memphis/memphis.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index 559bba0..21c872e 100644 --- a/memphis/memphis.py +++ b/memphis/memphis.py @@ -469,7 +469,7 @@ async def _single_station_producer( "req_version": 4, "username": self.username, "app_id": app_id, - "sdk_lang": "python3" + "sdk_lang": "python" } create_producer_req_bytes = json.dumps(create_producer_req, indent=2).encode( "utf-8" @@ -717,7 +717,7 @@ async def consumer( "req_version": 4, "username": self.username, "app_id": app_id, - "sdk_lang":"python3" + "sdk_lang":"python" } create_consumer_req_bytes = json.dumps(create_consumer_req, indent=2).encode(