From a24510f1d442c52631037e51fe282bd175a1fe27 Mon Sep 17 00:00:00 2001
From: extreme4all <>
Date: Mon, 11 Dec 2023 18:49:22 +0100
Subject: [PATCH] commit minor changes

---
 notes.md             | 1 +
 src_kafka/cleanup.py | 8 ++++----
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/notes.md b/notes.md
index 80e3caf..b046a22 100644
--- a/notes.md
+++ b/notes.md
@@ -24,6 +24,7 @@ powershell "(Get-Content requirements.txt) | ForEach-Object { $_ -replace '>=',
 ```
 
 ```
+kubectl port-forward -n kafka svc/kafka-service 9092:9092
 kubectl port-forward -n kafka svc/bd-prd-kafka-service 9094:9094
 kubectl port-forward -n kafka svc/bd-prd-kafdrop-service 9000:9000
 kubectl port-forward -n database svc/mysql 3306:3306
diff --git a/src_kafka/cleanup.py b/src_kafka/cleanup.py
index 65478a3..eaf86e1 100644
--- a/src_kafka/cleanup.py
+++ b/src_kafka/cleanup.py
@@ -21,7 +21,7 @@ def main():
                     # "session.timeout.ms":60000
                     "retention.bytes": 1_000_000_000,  # 1GB
                     "segment.bytes": 100_000_000,  # 100 mb
-                    "retention.ms": 3_600_000 * 4,  # 4 hours
+                    "retention.ms": 3_600_000 * 16,  # 16 hours
                     "segment.ms": 3_600_000,  # 1 hour minutes
                     # "cleanup.policy": "delete" ,
                 },
@@ -34,7 +34,7 @@ def main():
                     # "session.timeout.ms": 60000
                     "retention.bytes": 1_000_000_000,  # 1GB
                     "segment.bytes": 100_000_000,  # 100 mb
-                    "retention.ms": 3_600_000 * 4,  # 4 hours
+                    "retention.ms": 3_600_000 * 16,  # 16 hours
                     "segment.ms": 3_600_000,  # 1 hour minutes
                     # "cleanup.policy": "delete",
                 },
@@ -47,7 +47,7 @@ def main():
                     # "session.timeout.ms": 60000
                     "retention.bytes": 1_000_000_000,  # 1GB
                     "segment.bytes": 100_000_000,  # 100 mb
-                    "retention.ms": 3_600_000 * 4,  # 4 hours
+                    "retention.ms": 3_600_000 * 16,  # 16 hours
                     "segment.ms": 3_600_000,  # 1 hour minutes
                     # "cleanup.policy": "delete",
                 },
@@ -60,7 +60,7 @@ def main():
                     # "session.timeout.ms": 60000
                     "retention.bytes": 1_000_000_000,  # 1GB
                     "segment.bytes": 100_000_000,  # 100 mb
-                    "retention.ms": 3_600_000 * 4,  # 4 hours
+                    "retention.ms": 3_600_000 * 24,  # 24 hours
                     "segment.ms": 3_600_000,  # 1 hour minutes
                     # "cleanup.policy": "delete",
                 },