For 0.8, we have correlation id so we can potentially interleave requests/responses
There are a few levels of abstraction:
client = KafkaClient("localhost:9092") producer = KafkaProducer(client, "topic") producer.send_string("hello") consumer = KafkaConsumer(client, "group", "topic") consumer.seek(10, 2) # seek to beginning (lowest offset) consumer.commit() # commit it for msg in consumer.iter_messages(): print msg