"kafka_host": lambda value, _: (isinstance(value, str) and len(value) > 0)
if config_data.get("enable_ng_ro", True)
else True,
- "kafka_port": lambda value, _: (isinstance(value, int) and value > 0)
+ "kafka_port": lambda value, _: (isinstance(value, str) and len(value) > 0)
if config_data.get("enable_ng_ro", True)
else True,
"mongodb_connection_string": lambda value, _: (