diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2020-06-16 17:10:44 -0700 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2020-06-16 17:10:44 -0700 |
| commit | 9df71395046d045d7f8b568a55de4ea000de8791 (patch) | |
| tree | ca160903d63dca48a02706447a9003e7f369416d /python/grobid_tool.py | |
| parent | b839dcb734805397b8bf611eb77942b9555f4915 (diff) | |
| download | sandcrawler-9df71395046d045d7f8b568a55de4ea000de8791.tar.gz sandcrawler-9df71395046d045d7f8b568a55de4ea000de8791.zip | |
rename KafkaGrobidSink -> KafkaCompressSink
Diffstat (limited to 'python/grobid_tool.py')
| -rwxr-xr-x | python/grobid_tool.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/grobid_tool.py b/python/grobid_tool.py index a2d74a1..fe507a0 100755 --- a/python/grobid_tool.py +++ b/python/grobid_tool.py @@ -140,7 +140,7 @@ def main(): if args.kafka_mode: produce_topic = "sandcrawler-{}.grobid-output-pg".format(args.kafka_env) print("Running in kafka output mode, publishing to {}\n".format(produce_topic)) - args.sink = KafkaGrobidSink(kafka_hosts=args.kafka_hosts, + args.sink = KafkaCompressSink(kafka_hosts=args.kafka_hosts, produce_topic=produce_topic) args.func(args) |