acks="all",

Bot-detector · Dec 10, 2023 · b20a406 · b20a406
1 parent 894b216
commit b20a406
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -8,7 +8,7 @@
         "editor.defaultFormatter": "ms-python.black-formatter",
         "editor.formatOnSave": true,
         "editor.codeActionsOnSave": {
-            "source.organizeImports": true
+            "source.organizeImports": "explicit"
         },
       },
       "isort.args":["--profile", "black"],

diff --git a/src/jobs/kafka/players/main.py b/src/jobs/kafka/players/main.py
@@ -21,6 +21,7 @@ async def kafka_producer():
     producer = AIOKafkaProducer(
         bootstrap_servers=[APPCONFIG.KAFKA_HOST],
         value_serializer=lambda v: json.dumps(v).encode(),
+        acks="all",
     )
     await producer.start()
     return producer