commit minor changes

Bot-detector · Dec 11, 2023 · a24510f · a24510f
1 parent 2154d0c
commit a24510f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git 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
@@ -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",
                 },