diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-20 12:23:05 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-20 12:23:05 -0800 |
| commit | 069a30366b87415efa4a0c8ae804dea46bcdfc67 (patch) | |
| tree | b5b202f6a5d398b63adbf9978e636bd0fc7c5e67 /python/fatcat_import.py | |
| parent | 07f9d46ea06ccee867369b759c00c6bfe9b91b13 (diff) | |
| download | fatcat-069a30366b87415efa4a0c8ae804dea46bcdfc67.tar.gz fatcat-069a30366b87415efa4a0c8ae804dea46bcdfc67.zip | |
correct kafka topic names
Diffstat (limited to 'python/fatcat_import.py')
| -rwxr-xr-x | python/fatcat_import.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/fatcat_import.py b/python/fatcat_import.py index 555d4083..aad4ee57 100755 --- a/python/fatcat_import.py +++ b/python/fatcat_import.py @@ -11,7 +11,7 @@ def run_crossref(args): args.extid_map_file, create_containers=(not args.no_create_containers)) if args.kafka_mode: consumer = make_kafka_consumer( - args.kafka_hosts, args.kafka_env, "crossref", "fatcat-import") + args.kafka_hosts, args.kafka_env, "api-crossref", "fatcat-import") fci.process_batch(consumer, size=args.batch_size, decode_kafka=True) else: fci.process_batch(args.json_file, size=args.batch_size) |