aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2020-01-28 13:07:16 -0800
committerBryan Newbold <bnewbold@archive.org>2020-01-28 13:07:16 -0800
commite0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1 (patch)
tree3d2327c4f271ec8691dc71e5c95a10d19fb80825
parentf22390203f03907f3a49ff9a24fb1a5ec40c65f1 (diff)
downloadsandcrawler-e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1.tar.gz
sandcrawler-e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1.zip
fix kafka worker partition-specific error
-rw-r--r--python/sandcrawler/workers.py2
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