__init__.py 文件源码

def get_consumer_backend(topic_name, **kwargs):
    default = 'logpipe.backend.kafka.Consumer'
    backend_path = settings.get('CONSUMER_BACKEND', default)
    return import_string(backend_path)(topic_name, **kwargs)