Offset is going ahead and we are missing message with lag about kafka-go HOT 3 OPEN

go func() {
		for {

			msg, err := ki.Reader.FetchMessage(context.Background())
			if err != nil {
				vlog.Errorf("Error reading message: %v", err)
				continue
			}
			// TO-DO

			// Commit the message after processing
            if err := ki.Reader.CommitMessages(context.Background(), msg); err != nil {
                vlog.Errorf("Error committing message: %v", err)
            }
		}
	}()