Summary

The setOffsetForDatasourcesOnPartition() mutation sets the read offset for a specified ingest partition on a LogScale cluster node. The offset determines where LogScale begins reading data for all datasources on that partition. Use this mutation to replay data from an earlier offset or to skip past a corrupted segment.

API Stability Short-Term

Syntax

graphql
setOffsetForDatasourcesOnPartition(
      input: SetOffsetForDatasourcesOnPartitionInput!
   ): Boolean!

The mutation accepts a single required input argument of type SetOffsetForDatasourcesOnPartitionInput. Provide the target partition ID and the starting offset value in that input object. The Input Parameters section describes each field.

The mutation returns Boolean!: true when the offset is set successfully, or false if the operation does not complete.

Example

Raw
graphql
mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}
Mac OS or Linux (curl)
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql \
    -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json" \
    -d @- << EOF
{"query" : "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}"
}
EOF
Mac OS or Linux (curl) One-line
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql \
    -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json" \
    -d @- << EOF
{"query" : "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}"
}
EOF
Windows Cmd and curl
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql ^
    -H "Authorization: Bearer $TOKEN" ^
    -H "Content-Type: application/json" ^
    -d @'{"query" : "mutation { ^
  setOffsetForDatasourcesOnPartition( input: ^
    { ^
     partition: 4 ^
     offset: 10 ^
    } ^
  ) ^
}" ^
} '
Windows Powershell and curl
powershell
curl.exe -X POST 
    -H "Authorization: Bearer $TOKEN"
    -H "Content-Type: application/json"
    -d '{"query" : "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}"
}'
    "$YOUR_LOGSCALE_URL/graphql"
Perl
perl
#!/usr/bin/perl

use HTTP::Request;
use LWP;

my $TOKEN = "TOKEN";

my $uri = '$YOUR_LOGSCALE_URL/graphql';

my $query = "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}";
$query =~ s/\n/ /g;
my $json = sprintf('{"query" : "%s"}',$query);
my $req = HTTP::Request->new("POST", $uri );

$req->header("Authorization" => "Bearer $TOKEN");
$req->header("Content-Type" => "application/json");

$req->content( $json );

my $lwp = LWP::UserAgent->new;

my $result = $lwp->request( $req );

print $result->{"_content"},"\n";
Python
python
#! /usr/local/bin/python3

import requests

url = '$YOUR_LOGSCALE_URL/graphql'
mydata = r'''{"query" : "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}"
}'''

resp = requests.post(url,
                     data = mydata,
                     headers = {
   "Authorization" : "Bearer $TOKEN",
   "Content-Type" : "application/json"
}
)

print(resp.text)
Node.js
javascript
const https = require('https');

const data = JSON.stringify(
    {"query" : "mutation {
  setOffsetForDatasourcesOnPartition( input:
    {
     partition: 4
     offset: 10
    }
  )
}"
}
);


const options = {
  hostname: '$YOUR_LOGSCALE_URL',
  path: 'graphql',
  port: 443,
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Content-Length': data.length,
    Authorization: 'BEARER ' + process.env.TOKEN,
    'User-Agent': 'Node',
  },
};

const req = https.request(options, (res) => {
  let data = '';
  console.log(`statusCode: ${res.statusCode}`);

  res.on('data', (d) => {
    data += d;
  });
  res.on('end', () => {
    console.log(JSON.parse(data).data);
  });
});

req.on('error', (error) => {
  console.error(error);
});

req.write(data);
req.end();
Example Responses
Success (HTTP Response Code 200 OK)
json
{
  "data": {
    "setOffsetForDatasourcesOnPartition": true
  }
}

Input Parameters

Supply both required fields in the SetOffsetForDatasourcesOnPartitionInput object: the ingest partition to target and the starting offset position.

Table: SetOffsetForDatasourcesOnPartitionInput Input Datatype

ParameterTypeRequiredDefaultStabilityAvailabilityDescription
Some input parameters may be required, as indicated in the Required column. For return values, this indicates that you are assured a value if the field is requested for the results. 
Table last updated: Oct 14, 2026 
offsetLongyes Preview The starting offset for the ingest partition.
partitionIntyes Preview The ingest partition for which to set the offset.

Returned Values

The mutation returns Boolean!. A value of true indicates the offset was set successfully. A value of false indicates the operation failed. To confirm the partition state after the call, use the cluster() query and inspect the ingestPartitions field on the target node.