Fixed constructor
This commit is contained in:
parent
57519ed114
commit
c4dc0fd9ae
1 changed files with 1 additions and 1 deletions
|
@ -51,7 +51,7 @@ def get_backend(config):
|
|||
and 'pusher' in config['backend.kafka'] \
|
||||
and config['backend.kafka']['pusher']:
|
||||
c = config['backend.kafka']
|
||||
return KafkaBackend(server=c['server'], topic=c['topic'])
|
||||
return KafkaBackend({'server':c['server'], 'topic':c['topic']})
|
||||
|
||||
def main():
|
||||
config = parse_config_file()
|
||||
|
|
Loading…
Reference in a new issue