diff options
| author | David Arthur <mumrah@gmail.com> | 2013-03-08 19:56:51 -0500 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-04-02 20:19:30 -0400 |
| commit | 1b721325fe6b170cdfe001749dbd7b750fe59512 (patch) | |
| tree | 41a2560b287875944df737ca367aa823058914f3 /kafka/NOTES.md | |
| parent | 8fab55ad198eea41513a5daac3e92a709cb39247 (diff) | |
| download | kafka-python-1b721325fe6b170cdfe001749dbd7b750fe59512.tar.gz | |
Started on a simple producer and consumer
Diffstat (limited to 'kafka/NOTES.md')
| -rw-r--r-- | kafka/NOTES.md | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/kafka/NOTES.md b/kafka/NOTES.md index 8be6282..7cec39e 100644 --- a/kafka/NOTES.md +++ b/kafka/NOTES.md @@ -5,3 +5,13 @@ 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 |