kakfa-python consumer

#!/usr/bin/env python

from kafka import KafkaConsumer
from kafka import TopicPartition
import time

topic = TopicPartition('test',0)

# Create connection to Kafka broker
consumer = KafkaConsumer(bootstrap_servers='localhost:9092', group_id=None)

# Assign partition list for the consumer
consumer.assign([topic])

# Get position of next reccord
position = consumer.position(topic)

# Specify to fetch the last message
consumer.seek(topic, position - 1)

message = consumer.poll(1000)

# Close conection to broker
consumer.close()

print('Message   : ' + str(message[topic][0].value))
print('Timestamp : ' + str(message[topic][0].timestamp))

print message
print ( int(time.time()) - int(message[topic][0].timestamp/1000) )
print message[topic][0].timestamp