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