Merge pull request #389 from a-shkarupin/assertion_message

add assertion error description for easier debugging
scrapinghub · Nov 29, 2019 · 84f9e10 · 84f9e10
2 parents b98accd + d5f5905
commit 84f9e10
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/frontera/contrib/messagebus/kafkabus.py b/frontera/contrib/messagebus/kafkabus.py
@@ -190,7 +190,8 @@ def __init__(self, messagebus):
 
     def consumer(self, partition_id):
         c = Consumer(self._location, self._enable_ssl, self._cert_path, self._topic, self._general_group, partition_id)
-        assert len(c._consumer.partitions_for_topic(self._topic)) == self._partitions
+        assert len(c._consumer.partitions_for_topic(self._topic)) == self._partitions, \
+            "Number of kafka topic partitions doesn't match value in config for spider feed"
         return c
 
     def available_partitions(self):