diff options
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) |