chrislu
|
3ff6b31d94
|
sub broker wait for partition
|
11 months ago |
chrislu
|
2beaa2d0b3
|
pub/sub brokers check filer for assigned partitions
|
11 months ago |
chrislu
|
c3f8530f97
|
refactor
|
11 months ago |
chrislu
|
5f35857cd0
|
no need to assign partitions explicitly
|
11 months ago |
chrislu
|
428fea45f3
|
updated and added assignments
|
11 months ago |
chrislu
|
e8b05ecc91
|
add/remove assigned partitions
|
11 months ago |
chrislu
|
861ad732ca
|
refactor
|
11 months ago |
chrislu
|
47924afa1c
|
refactor
|
11 months ago |
chrislu
|
581cf6644c
|
lookup reads from filer instead of local memory
|
11 months ago |
chrislu
|
7121ae9617
|
separate out read topic conf and ensure topic active assignments
|
11 months ago |
chrislu
|
c77d35313e
|
pub/sub broker only check local assigned partitions
|
11 months ago |
chrislu
|
b0a2e9aea3
|
fix assignments if brokers changed
|
11 months ago |
chrislu
|
9ce7c482b3
|
refactor
|
11 months ago |
chrislu
|
a5b906c0dd
|
refactor
|
11 months ago |
chrislu
|
34839237ab
|
refactor
|
11 months ago |
chrislu
|
2828ccbb30
|
refactor
|
11 months ago |
chrislu
|
541140f735
|
rename
|
11 months ago |
chrislu
|
c8090b1f99
|
send assignments to newly connected subscribers
|
11 months ago |
chrislu
|
c616081ab9
|
refactor
|
11 months ago |
chrislu
|
bc8d2a01cc
|
create local topic partition from config on filer
|
11 months ago |
chrislu
|
fdf0ea8e11
|
passing partition info
|
11 months ago |
chrislu
|
be0c426dc7
|
simplify to LookupTopicPartitions(topic)
|
11 months ago |
chrislu
|
db3670a3a5
|
simplify api
|
11 months ago |
chrislu
|
34a78ffad0
|
remove isForPublish from LookupTopicBrokers
also adds a return parameter: whether the topic exists or not
|
11 months ago |
chrislu
|
3795d8dca8
|
release local topic partition if no publisher and subscribers
|
11 months ago |
chrislu
|
f782165638
|
rename
|
11 months ago |
chrislu
|
dd1ec70e62
|
rename
|
11 months ago |
chrislu
|
ba73199174
|
reuse local partition
|
11 months ago |
chrislu
|
7e6497cc1c
|
adjust publisher subscriber
|
11 months ago |
chrislu
|
026c54a9bb
|
fix publisher
|
11 months ago |
chrislu
|
fa59a5d67e
|
read from disk if not in memory
|
11 months ago |
chrislu
|
3aa3991f0f
|
adjust client side logs
|
12 months ago |
chrislu
|
7afaad31a4
|
wait on local topic partition creation
|
12 months ago |
chrislu
|
61dbdd0ff6
|
log ctrl messages
|
12 months ago |
chrislu
|
f750a5e03b
|
passing timestamp
|
12 months ago |
chrislu
|
45994641e9
|
lint
|
12 months ago |
chrislu
|
6a7a679137
|
passing partition generation timestamp
|
12 months ago |
chrislu
|
8af61dec91
|
avoid empty spaces in file name
|
12 months ago |
chrislu
|
aed54eda61
|
refactor
|
12 months ago |
chrislu
|
d51efddf5c
|
flush to disk
Need to do: read from disk
|
12 months ago |
chrislu
|
49428a303b
|
add batch index for each memory buffer
|
12 months ago |
chrislu
|
d0d24f1e40
|
rename functions
|
12 months ago |
chrislu
|
aa5b6a8187
|
adjust logs
|
12 months ago |
chrislu
|
496fc8fbbf
|
refactor
|
12 months ago |
chrislu
|
e8611ed85d
|
subscribe with partition offset
|
12 months ago |
chrislu
|
531f854af2
|
rename functions
|
12 months ago |
chrislu
|
f8787a9761
|
rename functions
|
12 months ago |
chrislu
|
ddd0fde094
|
rename functions
|
12 months ago |
chrislu
|
ee41dbb7fc
|
rename functions
|
12 months ago |
chrislu
|
47a4963d7a
|
subscription start from specified timestamp
|
12 months ago |