This is a starting point blog post where different things I learn about using Python Kafka will be documented.

Getting the Value out of a Consumer Record

The output of a Python Kafka call is a Consumer Record which is a "set of named tuples (blah blah blah)" where what you actually want is the value tuple. This can be gotten with the .value attribute:

#!/usr/bin/env python
from kafka import KafkaConsumer
consumer = KafkaConsumer(
    value_deserializer=lambda m: json.loads(m.decode('utf-8')),
for msg in consumer:
    # this is what you actually want; 
    print msg.value
    # process msg here

See Also

Stack Overflow