Remove old design notes from Kafka 8 era (#876)
This commit is contained in:
@@ -1,32 +0,0 @@
|
||||
For 0.8, we have correlation id so we can potentially interleave requests/responses
|
||||
|
||||
There are a few levels of abstraction:
|
||||
|
||||
* Protocol support: encode/decode the requests/responses
|
||||
* Socket support: send/recieve messages
|
||||
* API support: higher level APIs such as: get_topic_metadata
|
||||
|
||||
|
||||
# Methods of producing
|
||||
|
||||
* Round robbin (each message to the next partition)
|
||||
* All-to-one (each message to one partition)
|
||||
* All-to-all? (each message to every partition)
|
||||
* Partitioned (run each message through a partitioning function)
|
||||
** HashPartitioned
|
||||
** FunctionPartition
|
||||
|
||||
# Possible API
|
||||
|
||||
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
|
||||
|
||||
|
||||
Reference in New Issue
Block a user