337 Commits (e4c27de1ecd915ebbfeea56493b256e0680ea0cd)

Author SHA1 Message Date
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 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 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
chrislu 35869b5c80 subscriber can be notified of the assignment change when topic is just configured 12 months ago
chrislu efb695fd93 lookup existing topic partitions 12 months ago
chrislu 8b4cd50aac log errors 12 months ago