diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2016-11-14 11:02:34 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2016-11-14 11:02:34 -0800 |
commit | eb6801da35c14f7c28d9d7f441f301a146e4d0db (patch) | |
tree | 04846239a734e091b7d13fe71b3e3915d60edb1e | |
parent | 8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457 (diff) | |
download | kafka-python-eb6801da35c14f7c28d9d7f441f301a146e4d0db.tar.gz |
Remove old design notes from Kafka 8 era (#876)
-rw-r--r-- | kafka/NOTES.md | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/kafka/NOTES.md b/kafka/NOTES.md deleted file mode 100644 index 8fb0f47..0000000 --- a/kafka/NOTES.md +++ /dev/null @@ -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 - - |