From 44792151c995564adc2c11e8acd075ff2a163f02 Mon Sep 17 00:00:00 2001
From: Noah Levitt <nlevitt@archive.org>
Date: Fri, 4 Sep 2015 21:00:48 +0000
Subject: [PATCH] tiny fix to make it work!

---
 warcprox/kafkafeed.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/warcprox/kafkafeed.py b/warcprox/kafkafeed.py
index 65f3f1d..dd8a0a8 100644
--- a/warcprox/kafkafeed.py
+++ b/warcprox/kafkafeed.py
@@ -13,7 +13,7 @@ class CaptureFeed:
         self._producer = kafka.SimpleProducer(kafka.KafkaClient(broker_list))
 
     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
 
         try: