{"record":{"id":"a68bd08d1cc37e9c","repo":"apache/druid","slug":"exception-while-attempting-to-automatically-reset","errorCode":null,"errorMessage":"Exception while attempting to automatically reset sequences for partitions[%s]","messagePattern":"Exception while attempting to automatically reset sequences for partitions\\[(.+?)\\]","errorType":"exception","errorClass":"IllegalStateException","httpStatus":null,"severity":"error","filePath":"extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskRunner.java","lineNumber":146,"sourceCode":"\n      if (!partitionToSequenceResetMap.isEmpty()) {\n        for (Map.Entry<StreamPartition<String>, String> partitionToSequence : partitionToSequenceResetMap.entrySet()) {\n          log.warn(\"Starting sequenceNumber[%s] is no longer available for partition[%s].\",\n                   partitionToSequence.getValue(),\n                   partitionToSequence.getKey()\n          );\n        }\n        if (task.getTuningConfig().isResetOffsetAutomatically()) {\n          log.info(\n              \"Attempting to reset offsets for [%d] partitions with ids[%s].\",\n              partitionToSequenceResetMap.size(),\n              partitionToSequenceResetMap.keySet()\n          );\n          try {\n            sendResetRequestAndWait(partitionToSequenceResetMap, toolbox);\n          }\n          catch (IOException e) {\n            throw new ISE(\n                e,\n                \"Exception while attempting to automatically reset sequences for partitions[%s]\",\n                partitionToSequenceResetMap.keySet()\n            );\n          }\n        } else {\n          throw new ISE(\n              \"Automatic offset reset is disabled, but there are partitions with unavailable sequence numbers [%s].\",\n              partitionToSequenceResetMap\n          );\n        }\n      }\n    }\n  }\n\n  @Override\n  protected boolean isEndOffsetExclusive()\n  {","sourceCodeStart":128,"sourceCodeEnd":164,"githubUrl":"https://github.com/apache/druid/blob/9b90983fd291f26935af934383ce360473179e4d/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskRunner.java#L128-L164","documentation":"Error while executing automatic offset reset in KinesisIndexTaskRunner.possiblyResetDataSourceMetadata: starting sequence numbers for some partitions are no longer available in the stream (expired records), and although isResetOffsetAutomatically was enabled, the reset request (sendResetRequestAndWait) failed — typically an ISE/IOException while coordinating sequence resets with the overlord.","triggerScenarios":"Thrown at extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskRunner.java:146 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Check overlord connectivity from the task; the reset goes through a reset API call and waits for confirmation.","Manually reset offsets for the affected partitions via the supervisor reset endpoint.","Increase Kinesis retention or fix checkpointing so sequences do not expire; consider disabling auto-reset to handle it manually."],"exampleFix":null,"handlingStrategy":"retry","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"9b90983fd291f26935af934383ce360473179e4d","analyzedAt":"2026-09-07T13:32:30.957Z","contentChangedAt":"2026-09-07T13:32:30.957Z","schemaVersion":2},"datasetVersion":"2026-09-17T15:17:12.973Z"}