gistfile1.txt

import kafka.consumer
import sys

offset = int(sys.argv[1])
print "Input offset: %s" % offset


consumer = kafka.consumer.Consumer('test', host='msg-keeper-0', port=9090, offset=offset)

for message in consumer.loop():
    print message




import kafka
import time
import sys

msg = sys.argv[1]

producer = kafka.producer.Producer('test', host='msg-keeper-0', port=9090)
message1 = kafka.message.Message(msg)

producer.send([message1])