aboutsummaryrefslogtreecommitdiff
AgeCommit message (Expand)AuthorFilesLines
2024-05-20track offsetchrislu9-183/+215
2024-05-20add InflightMessageTrackerchrislu2-0/+205
2024-05-19fixchrislu1-1/+1
2024-05-19ConcurrentPartitionLimitchrislu3-15/+23
2024-05-19less logschrislu1-1/+1
2024-05-19start consuming ASAPchrislu5-307/+357
2024-05-19logschrislu1-1/+1
2024-05-19persist consumer group offsetchrislu18-530/+601
2024-05-17renamechrislu1-12/+12
2024-05-17add subscribe followerchrislu5-244/+823
2024-05-16consumer acks received messageschrislu4-21/+57
2024-05-16adjust errorschrislu2-4/+5
2024-05-14remove logschrislu1-1/+0
2024-05-14subscriber receives partitions and dispatch to processorschrislu4-36/+104
2024-05-14move initial assignment to rebalance logicchrislu3-19/+14
2024-05-14move read write topic config into filer client accessorchrislu7-55/+83
2024-05-13refactorchrislu3-26/+98
2024-05-13renamechrislu1-3/+3
2024-05-13consumer instance passing MaxPartitionCount to coordinatorchrislu6-4/+19
2024-05-13refactorchrislu2-20/+20
2024-05-10clean up unused variableschrislu3-5/+0
2024-05-073.673.67chrislu2-3/+3
2024-05-07also delete parent folder if emptychrislu1-1/+1
2024-05-07Fix deadlock in lock table locks (#5566)Patrick Schmidt1-6/+13
2024-05-06chore(deps): bump golang.org/x/tools from 0.19.0 to 0.21.0 (#5564)dependabot[bot]2-17/+18
2024-05-06chore(deps): bump github.com/hanwen/go-fuse/v2 from 2.5.0 to 2.5.1 (#5559)dependabot[bot]2-3/+3
2024-05-06chore(deps): bump github.com/parquet-go/parquet-go from 0.20.1 to 0.21.0 (#5560)dependabot[bot]2-3/+3
2024-05-06chore(deps): bump google.golang.org/api from 0.176.0 to 0.177.0 (#5562)dependabot[bot]2-20/+21
2024-05-06chore(deps): bump golang.org/x/sys from 0.19.0 to 0.20.0 (#5563)dependabot[bot]2-3/+3
2024-05-053.663.66chrislu2-3/+3
2024-05-05fix testchrislu1-5/+5
2024-05-05add some delay when starting filers, to simulate real productionorigin/mq-subscribechrislu1-0/+1
2024-05-05add delaychrislu1-2/+5
2024-05-05reset last errorchrislu1-0/+1
2024-05-05init candidate servers when setting a starting snapshotchrislu1-0/+4
2024-05-05ensure head index is within rangechrislu1-2/+8
2024-05-05logchrislu1-0/+5
2024-05-05ignorechrislu1-0/+4
2024-05-03workingchrislu3-5/+7
2024-05-02renamechrislu8-44/+44
2024-05-02subscriber can unmarshal the recordchrislu2-4/+94
2024-05-02renamechrislu1-0/+0
2024-05-02rename field typeschrislu10-54/+54
2024-05-02consistent with protobuf data typeschrislu7-36/+36
2024-05-02add example to publish a recordchrislu2-1/+134
2024-05-02renamechrislu2-1/+2
2024-05-02rename to WithField()chrislu4-36/+36
2024-05-02Merge branch 'master' into mq-subscribechrislu2-2/+4
2024-04-29Merge branch 'master' into mq-subscribechrislu7-94/+89
2024-04-29reduce ambiguity about use memory_sequencer (#5555)shenxingwuying2-2/+4