From 9638a425a49b77f45dc859496cdf4d3ffdde437a Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Tue, 28 Nov 2023 13:28:26 +0200 Subject: [PATCH 1/2] change the retention_value to 1 hour --- memphis/memphis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index 0e7ec9c..59ee2de 100644 --- a/memphis/memphis.py +++ b/memphis/memphis.py @@ -237,7 +237,7 @@ async def station( self, name: str, retention_type: Retention = Retention.MAX_MESSAGE_AGE_SECONDS, - retention_value: int = 604800, + retention_value: int = 3600, storage_type: Storage = Storage.DISK, replicas: int = 1, idempotency_window_ms: int = 120000, From 513941033580a4ebe3178f28f683baad66d903e8 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Tue, 28 Nov 2023 13:45:02 +0200 Subject: [PATCH 2/2] readme --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 012cb69..f889f30 100644 --- a/README.md +++ b/README.md @@ -231,7 +231,7 @@ _If the station trying to be created exists when this function is called, nothin self, name: str, retention_type: Retention = Retention.MAX_MESSAGE_AGE_SECONDS, # MAX_MESSAGE_AGE_SECONDS/MESSAGES/BYTES/ACK_BASED(cloud only). Defaults to MAX_MESSAGE_AGE_SECONDS - retention_value: int = 604800, # defaults to 604800 + retention_value: int = 3600, # defaults to 3600 storage_type: Storage = Storage.DISK, # Storage.DISK/Storage.MEMORY. Defaults to DISK replicas: int = 1, idempotency_window_ms: int = 120000, # defaults to 2 minutes