kafka tail decoding transit messages

from transit.reader import Reader
from kafka import KafkaConsumer
from StringIO import StringIO

topic = ''
kafka_brokers = []

consumer = KafkaConsumer(topic,
                         group_id='my_group',
                         bootstrap_servers=kafka_brokers,
                         auto_offset_reset='largest')

reader = Reader("json")

for message in consumer:
    print("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition, message.offset, message.key, reader.read(StringIO(message.value))))