lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-10-15 20:06:19 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

publish init add followers

Browse Source
This commit is contained in:
chrislu
2024-02-29 09:39:12 -08:00
parent 1b4484bf0a
commit ead27a4f59
3 changed files with 182 additions and 169 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
weed/mq/client/pub_client/scheduler.go
View File

@@ -141,9 +141,10 @@ func (p *TopicPublisher) doPublishToPartition(job *EachPartitionPublishJob) erro
if err = publishClient.Send(&mq_pb.PublishMessageRequest{
Message: &mq_pb.PublishMessageRequest_Init{
Init: &mq_pb.PublishMessageRequest_InitMessage{
Topic: p.config.Topic.ToPbTopic(),
Partition: job.Partition,
AckInterval: 128,
Topic: p.config.Topic.ToPbTopic(),
Partition: job.Partition,
AckInterval: 128,
FollowerBrokers: job.FollowerBrokers,
},
},
}); err != nil {