chrislu
ec155022e7
"golang.org/x/exp/slices" => "slices" and go fmt
3 days ago
Chris Lu
dc784bf217
merge current message queue code changes ( #6201 )
* listing files to convert to parquet
* write parquet files
* save logs into parquet files
* pass by value
* compact logs into parquet format
* can skip existing files
* refactor
* refactor
* fix compilation
* when no partition found
* refactor
* add untested parquet file read
* rename package
* refactor
* rename files
* remove unused
* add merged log read func
* parquet wants to know the file size
* rewind by time
* pass in stop ts
* add stop ts
* adjust log
* minor
* adjust log
* skip .parquet files when reading message logs
* skip non message files
* Update subscriber_record.go
* send messages
* skip message data with only ts
* skip non log files
* update parquet-go package
* ensure a valid record type
* add new field to a record type
* Update read_parquet_to_log.go
* fix parquet file name generation
* separating reading parquet and logs
* add key field
* add skipped logs
* use in memory cache
* refactor
* refactor
* refactor
* refactor, and change compact log
* refactor
* rename
* refactor
* fix format
* prefix v to version directory
2 months ago
chrislu
25b2850e7d
refactor out FilerClientAccessor
7 months ago
chrislu
d1f0c40402
remove per-message debug logs
7 months ago
chrislu
df9d889489
fix size calculation
7 months ago
chrislu
f7b818483a
fix cases when buffer wraps around
7 months ago
chrislu
ad2b878130
fix inflight message tracker
7 months ago
chrislu
f0b9e163a0
avoid nil stopChan
7 months ago
chrislu
a5874954dc
less logs
7 months ago
chrislu
edc87c16f9
balance subscribers
need to ensure the offsets are persisted
7 months ago
chrislu
6366898af2
add market
7 months ago
chrislu
96b326a304
use type ConsumerGroupInstanceId
7 months ago
chrislu
37d1ee562d
refactor
7 months ago
chrislu
d40b350f54
coordinator receives unassignment ack
7 months ago
chrislu
554ae09f82
rename
7 months ago
chrislu
6ef2d010aa
rename file
7 months ago
chrislu
67e6051585
rename Coordinator to SubCoordinator
7 months ago
chrislu
d5abffa42c
rename Balancer to PubBalancer
7 months ago
chrislu
2190d59bc3
refactor
ToDo
1. handle unassignment on client side
2. get notified of completed unassignment
3. in consumer_group.go, balance and send unassignment
7 months ago
chrislu
3148dec1f6
avoid concurrent processing for the same key
7 months ago
chrislu
3622196881
go fmt
7 months ago
chrislu
d8ab22012a
track offset
7 months ago
chrislu
2b07a40da5
add InflightMessageTracker
7 months ago
chrislu
c6db3f31a1
start consuming ASAP
7 months ago
chrislu
b1871427c3
persist consumer group offset
1. use one follower
2. read write consumer group offset
7 months ago
chrislu
759a8e50cf
remove logs
7 months ago
chrislu
972e9faaa2
move initial assignment to rebalance logic
7 months ago
chrislu
6e5075e14e
move read write topic config into filer client accessor
7 months ago
chrislu
ac63f2b5a1
refactor
7 months ago
chrislu
844a1a0192
rename
7 months ago
chrislu
372bd8d71d
consumer instance passing MaxPartitionCount to coordinator
7 months ago
chrislu
2142842f82
refactor
7 months ago
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.
9 months ago
chrislu
1b4484bf0a
go fmt
10 months ago
chrislu
34839237ab
refactor
11 months ago
chrislu
2828ccbb30
refactor
11 months ago
chrislu
f750a5e03b
passing timestamp
12 months ago
chrislu
6a7a679137
passing partition generation timestamp
12 months ago
chrislu
35869b5c80
subscriber can be notified of the assignment change when topic is just configured
Next: Subscriber needs to read by the timestamp offset.
12 months ago
chrislu
2845230329
passing broker into the assignments
12 months ago
chrislu
093fdc1621
subscriber can get assignments
12 months ago
chrislu
c950a40aad
subscriber keep connected to the balancer
12 months ago
chrislu
e0727071c8
go fmt
1 year ago
Chris Lu
580940bf82
Merge accumulated changes related to message queue ( #5098 )
* balance partitions on brokers
* prepare topic partition first and then publish, move partition
* purge unused APIs
* clean up
* adjust logs
* add BalanceTopics() grpc API
* configure topic
* configure topic command
* refactor
* repair missing partitions
* sequence of operations to ensure ordering
* proto to close publishers and consumers
* rename file
* topic partition versioned by unixTimeNs
* create local topic partition
* close publishers
* randomize the client name
* wait until no publishers
* logs
* close stop publisher channel
* send last ack
* comments
* comment
* comments
* support list of brokers
* add cli options
* Update .gitignore
* logs
* return io.eof directly
* refactor
* optionally create topic
* refactoring
* detect consumer disconnection
* sub client wait for more messages
* subscribe by time stamp
* rename
* rename to sub_balancer
* rename
* adjust comments
* rename
* fix compilation
* rename
* rename
* SubscriberToSubCoordinator
* sticky rebalance
* go fmt
* add tests
* balance partitions on brokers
* prepare topic partition first and then publish, move partition
* purge unused APIs
* clean up
* adjust logs
* add BalanceTopics() grpc API
* configure topic
* configure topic command
* refactor
* repair missing partitions
* sequence of operations to ensure ordering
* proto to close publishers and consumers
* rename file
* topic partition versioned by unixTimeNs
* create local topic partition
* close publishers
* randomize the client name
* wait until no publishers
* logs
* close stop publisher channel
* send last ack
* comments
* comment
* comments
* support list of brokers
* add cli options
* Update .gitignore
* logs
* return io.eof directly
* refactor
* optionally create topic
* refactoring
* detect consumer disconnection
* sub client wait for more messages
* subscribe by time stamp
* rename
* rename to sub_balancer
* rename
* adjust comments
* rename
* fix compilation
* rename
* rename
* SubscriberToSubCoordinator
* sticky rebalance
* go fmt
* add tests
* tracking topic=>broker
* merge
* comment
1 year ago