Skip to content

Commit

Permalink
Fix comitting with metadata
Browse files Browse the repository at this point in the history
Signed-off-by: Ganesh Vernekar <ganeshvern@gmail.com>
  • Loading branch information
codesome committed Jun 12, 2024
1 parent 140e7eb commit 3e5e03f
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pkg/blockbuilder/blockbuilder.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ func New(
return newTSDBBuilder(b.logger, b.limits, b.cfg.BlocksStorageConfig)
}

bucketClient, err := bucket.NewClient(context.Background(), cfg.BlocksStorageConfig.Bucket, "ingester", logger, reg)
bucketClient, err := bucket.NewClient(context.Background(), cfg.BlocksStorageConfig.Bucket, "blockbuilder", logger, reg)
if err != nil {
return nil, fmt.Errorf("failed to create the bucket client: %w", err)
}
Expand Down Expand Up @@ -504,9 +504,9 @@ func (b *BlockBuilder) finalizePartition(ctx context.Context, commitRec, lastRec
if topic.Topic != b.cfg.Kafka.Topic {
continue
}
for _, part := range req.Topics[0].Partitions {
if part.Partition == commitRec.Partition {
part.Metadata = &meta
for i := range req.Topics[0].Partitions {
if req.Topics[0].Partitions[i].Partition == commitRec.Partition {
req.Topics[0].Partitions[i].Metadata = &meta
}
}
}
Expand Down

0 comments on commit 3e5e03f

Please sign in to comment.