From e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1 Mon Sep 17 00:00:00 2001
From: Bryan Newbold <bnewbold@archive.org>
Date: Tue, 28 Jan 2020 13:07:16 -0800
Subject: fix kafka worker partition-specific error

---
 python/sandcrawler/workers.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
 
-- 
cgit v1.2.3