From 396e085b1732dda32d95c3a58dc4b8bac8f83087 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Thu, 10 Aug 2023 00:51:15 +0300 Subject: [PATCH] fix error in producer & consumer --- memphis/memphis.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index a14d37b..59d5f71 100644 --- a/memphis/memphis.py +++ b/memphis/memphis.py @@ -411,7 +411,7 @@ async def producer( "station_name": station_name, "connection_id": self.connection_id, "producer_type": "application", - "req_version": 1, + "req_version": 2, "username": self.username } create_producer_req_bytes = json.dumps(create_producer_req, indent=2).encode( @@ -604,7 +604,7 @@ async def consumer( "max_msg_deliveries": max_msg_deliveries, "start_consume_from_sequence": start_consume_from_sequence, "last_messages": last_messages, - "req_version": 1, + "req_version": 2, "username": self.username }