diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2020-01-28 13:07:16 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2020-01-28 13:07:16 -0800 |
| commit | e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1 (patch) | |
| tree | 3d2327c4f271ec8691dc71e5c95a10d19fb80825 | |
| parent | f22390203f03907f3a49ff9a24fb1a5ec40c65f1 (diff) | |
| download | sandcrawler-e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1.tar.gz sandcrawler-e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1.zip | |
fix kafka worker partition-specific error
| -rw-r--r-- | python/sandcrawler/workers.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/sandcrawler/workers.py b/python/sandcrawler/workers.py index a110754..cb38146 100644 --- a/python/sandcrawler/workers.py +++ b/python/sandcrawler/workers.py @@ -397,7 +397,7 @@ def make_kafka_consumer(hosts, consume_topic, group): print("Kafka consumer commit error: {}".format(p.error), file=sys.stderr) print("Bailing out...", file=sys.stderr) # TODO: should it be sys.exit(-1)? - raise KafkaException(err) + raise KafkaException(p.error) #print("Kafka consumer commit successful") pass |