kafka.py 文件源码

def validate_config(_config):
        source_schema = voluptuous.Schema({
            "module": voluptuous.And(basestring, vu.NoSpaceCharacter()),
            "params": {
                "zk_host": voluptuous.And(basestring, vu.NoSpaceCharacter()),
                "zk_port": int,
                "group_id": voluptuous.And(basestring, vu.NoSpaceCharacter()),
                "topics": {
                    voluptuous.And(basestring, vu.NoSpaceCharacter()):
                    voluptuous.And(int, voluptuous.Range(min=1))
                }
            }
        }, required=True)
        return source_schema(_config)