Merge pull request #9 from thanos/master

fixes #8

Author: otoolep

stormkafkamon/processor.py

@@ -12,7 +12,8 @@ def emit(self, record):
 import struct
 import socket
 from collections import namedtuple
-from kafka.client import KafkaClient, OffsetRequest
+from kafka.client import KafkaClient
+from kafka.common import OffsetRequestPayload
 
 class ProcessorError(Exception):
     def __init__(self, msg):