backup/warcprox
1
0
Fork 0
mirror of https://github.com/internetarchive/warcprox.git synced 2025-01-18 13:22:09 +01:00
Code Issues Projects Releases Activity

tiny fix to make it work!

Browse Source
This commit is contained in:
Noah Levitt 2015-09-04 21:00:48 +00:00
parent 67beec4b80
commit 44792151c9
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
warcprox/kafkafeed.py
View File

@ -13,7 +13,7 @@ class CaptureFeed:
self._producer = kafka.SimpleProducer(kafka.KafkaClient(broker_list)) self._producer = kafka.SimpleProducer(kafka.KafkaClient(broker_list))
def notify(self, recorded_url, records): def notify(self, recorded_url, records):
if records[0].type not in ('revisit', 'response'): if records[0].type not in (b'revisit', b'response'):
return return
try: try: