diff --git a/pkg/blockbuilder/builder/builder.go b/pkg/blockbuilder/builder/builder.go index afc1a4a749530..ac8efc3b0bbd5 100644 --- a/pkg/blockbuilder/builder/builder.go +++ b/pkg/blockbuilder/builder/builder.go @@ -303,6 +303,7 @@ func (i *BlockBuilder) runOne(ctx context.Context, c *kgo.Client, workerID strin func (i *BlockBuilder) processJob(ctx context.Context, c *kgo.Client, job *types.Job, logger log.Logger) (lastOffsetConsumed int64, err error) { level.Debug(logger).Log("msg", "beginning job") + start := time.Now() indexer := newTsdbCreator() appender := newAppender(i.id, @@ -506,6 +507,7 @@ func (i *BlockBuilder) processJob(ctx context.Context, c *kgo.Client, job *types level.Info(logger).Log( "msg", "successfully processed job", "last_offset", lastOffset, + "duration", time.Since(start), ) return lastOffset, nil