 chrislu
|
25b2850e7d
refactor out FilerClientAccessor
|
7 months ago |
|
chrislu
|
f0b9e163a0
avoid nil stopChan
|
7 months ago |
|
chrislu
|
edc87c16f9
balance subscribers
|
7 months ago |
|
chrislu
|
96b326a304
use type ConsumerGroupInstanceId
|
7 months ago |
|
chrislu
|
37d1ee562d
refactor
|
8 months ago |
|
chrislu
|
d40b350f54
coordinator receives unassignment ack
|
8 months ago |
|
chrislu
|
d5abffa42c
rename Balancer to PubBalancer
|
8 months ago |
|
chrislu
|
2190d59bc3
refactor
|
8 months ago |
|
chrislu
|
3622196881
go fmt
|
8 months ago |
|
chrislu
|
c6db3f31a1
start consuming ASAP
|
8 months ago |
|
chrislu
|
b1871427c3
persist consumer group offset
|
8 months ago |
|
chrislu
|
759a8e50cf
remove logs
|
8 months ago |
|
chrislu
|
972e9faaa2
move initial assignment to rebalance logic
|
8 months ago |
|
chrislu
|
6e5075e14e
move read write topic config into filer client accessor
|
8 months ago |
|
chrislu
|
ac63f2b5a1
refactor
|
8 months ago |
|
chrislu
|
844a1a0192
rename
|
8 months ago |
|
chrislu
|
372bd8d71d
consumer instance passing MaxPartitionCount to coordinator
|
8 months ago |
|
chrislu
|
205d2285f3
setup follower by publisher
|
10 months ago |
|
chrislu
|
1b4484bf0a
go fmt
|
10 months ago |
|
chrislu
|
f750a5e03b
passing timestamp
|
1 year ago |
|
chrislu
|
35869b5c80
subscriber can be notified of the assignment change when topic is just configured
|
1 year ago |
|
chrislu
|
2845230329
passing broker into the assignments
|
1 year ago |
|
chrislu
|
093fdc1621
subscriber can get assignments
|
1 year ago |
|
chrislu
|
c950a40aad
subscriber keep connected to the balancer
|
1 year ago |
|
chrislu
|
e0727071c8
go fmt
|
1 year ago |
|
Chris Lu
|
580940bf82
Merge accumulated changes related to message queue (#5098)
|
1 year ago |
