blob: 71736e6cf25113de32a581c467b46c531afe7cf3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
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
|
