chrislu 205d2285f3 setup follower by publisher ...

* the subscriber would getOrGen a local partition and wait
* the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages.

2024-03-24 12:57:09 -07:00

..

connect_to_sub_coordinator.go

setup follower by publisher

2024-03-24 12:57:09 -07:00

subscribe.go

clean up dead code

2023-12-31 13:25:33 -08:00

subscriber.go

subscriber find broker leader first

2024-02-05 23:14:25 -08:00