Fix producer acks (#1135)

Author: muralibasani

src/karapace/core/config.py

@@ -9,11 +9,13 @@
 
 from collections.abc import Mapping
 from copy import deepcopy
+from typing import Literal
+
 from karapace.core.constants import DEFAULT_AIOHTTP_CLIENT_MAX_SIZE, DEFAULT_PRODUCER_MAX_REQUEST, DEFAULT_SCHEMA_TOPIC
 from karapace.core.typing import ElectionStrategy, NameStrategy
 from karapace.core.utils import json_encode
 from pathlib import Path
-from pydantic import BaseModel, ImportString
+from pydantic import BaseModel, ImportString, field_validator
 from pydantic_settings import BaseSettings, SettingsConfigDict
 
 import enum
@@ -118,7 +120,7 @@ class Config(BaseSettings):
     topic_name: str = DEFAULT_SCHEMA_TOPIC
     metadata_max_age_ms: int = 60000
     admin_metadata_max_age: int = 5
-    producer_acks: int = 1
+    producer_acks: int | Literal["all"] = 1
     producer_compression_type: str | None = None
     producer_count: int = 5
     producer_linger_ms: int = 100
@@ -156,6 +158,12 @@ def get_advertised_hostname(self) -> str:
     def get_address(self) -> str:
         return f"{self.host}:{self.port}"
 
+    @field_validator("producer_acks", mode="before")
+    def normalize_producer_acks(cls, v):
+        if isinstance(v, str) and v.lower() == "all":
+            return -1
+        return v
+
     def get_rest_base_uri(self) -> str:
         return (
             self.rest_base_uri