diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-16 12:05:32 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-16 12:05:32 -0800 |
| commit | 7ce8460a967c08ff836b60900984e6163995c148 (patch) | |
| tree | 388d45a1966f4ee563eb3f07cc6842d940c58688 | |
| parent | 08d33082b66730a792ee32e47c750a771540b081 (diff) | |
| download | kafka-python-7ce8460a967c08ff836b60900984e6163995c148.tar.gz | |
More notes
| -rw-r--r-- | notes.txt | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/notes.txt b/notes.txt new file mode 100644 index 0000000..71736e6 --- /dev/null +++ b/notes.txt @@ -0,0 +1,46 @@ +Group coordinator state machine: + + - process received events + - generate events to send + - state + - coordinator unknown + - inactive + - joined + - + - rebalancing + - active + +coordinator unknown, GroupCoordinatorResponse -> coordinator unknown +coordinator unknown, GroupCoordinatorResponse -> inactive +inactive, JoinGroupResponse -> joined +, JoinGroupResponse -> syncing +syncing, SyncGroupRequest -> syncing +syncing, SyncGroupResponse -> active + + + +KafkaClient router + + - send request + - route request to node + - all: + - apiversions + - saslhandshake + - any: + - metadata + - groupcoordinator + - offsetfetch / offsetcommit v0 + - createtopics / deletetopics + - listgroups / describegroups + - partition leader: + - fetch + - produce + - offset + - group coordinator: + - joingroup + - syncgroup + - leavegroup + - heartbeat + - offsetfetch / offsetcommit v1+ + - encode request to bytes + - queue bytes per node |