{"record":{"id":"b6d3c4f7c52b0090","repo":"apache/druid","slug":"the-maxrecordsperpoll-config-property-of-the-kin","errorCode":null,"errorMessage":"The 'maxRecordsPerPoll' config property of the kinesis tuning config has been deprecated. Please use 'maxBytesPerPoll'.","messagePattern":"The 'maxRecordsPerPoll' config property of the kinesis tuning config has been deprecated\\. Please use 'maxBytesPerPoll'\\.","errorType":"console","errorClass":null,"httpStatus":null,"severity":"info","filePath":"extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTask.java","lineNumber":103,"sourceCode":"        ioConfig,\n        context,\n        getFormattedGroupId(Configs.valueOrDefault(supervisorId, dataSchema.getDataSource()), TYPE),\n        serverPriority\n    );\n    this.useListShards = useListShards;\n    this.awsCredentialsConfig = awsCredentialsConfig;\n  }\n\n  @Override\n  public TaskStatus runTask(TaskToolbox toolbox)\n  {\n    this.runtimeInfo = toolbox.getAdjustedRuntimeInfo();\n    if (getTuningConfig().getRecordBufferSizeConfigured() != null) {\n      log.warn(\"The 'recordBufferSize' config property of the kinesis tuning config has been deprecated. \"\n               + \"Please use 'recordBufferSizeBytes'.\");\n    }\n    if (getTuningConfig().getMaxRecordsPerPollConfigured() != null) {\n      log.warn(\"The 'maxRecordsPerPoll' config property of the kinesis tuning config has been deprecated. \"\n               + \"Please use 'maxBytesPerPoll'.\");\n    }\n    return super.runTask(toolbox);\n  }\n\n  @Override\n  protected SeekableStreamIndexTaskRunner<String, String, KinesisRecordEntity> createTaskRunner()\n  {\n    //noinspection unchecked\n    return new KinesisIndexTaskRunner(this, lockGranularityToUse);\n  }\n\n  @Override\n  protected KinesisRecordSupplier newTaskRecordSupplier(final TaskToolbox toolbox)\n      throws RuntimeException\n  {\n    KinesisIndexTaskIOConfig ioConfig = ((KinesisIndexTaskIOConfig) super.ioConfig);\n    KinesisIndexTaskTuningConfig tuningConfig = ((KinesisIndexTaskTuningConfig) super.tuningConfig);","sourceCodeStart":85,"sourceCodeEnd":121,"githubUrl":"https://github.com/apache/druid/blob/9b90983fd291f26935af934383ce360473179e4d/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTask.java#L85-L121","documentation":"KinesisIndexTask.runTask() logs a deprecation warning when the tuning config's maxRecordsPerPoll field was explicitly set (getMaxRecordsPerPollConfigured() != null). The byte-based maxBytesPerPoll property replaces it. Execution continues; it is advisory only.","triggerScenarios":"Running a Kinesis indexing task whose tuning config contains the deprecated 'maxRecordsPerPoll' property.","commonSituations":"Legacy specs retained across a Druid upgrade; templates or IaC still emitting maxRecordsPerPoll; mixed configs where some tasks use old and some new fields.","solutions":["Replace 'maxRecordsPerPoll' with 'maxBytesPerPoll' in the tuning config.","Estimate bytes per poll from average record size times desired records per poll.","Update task-generation tooling and stored supervisor specs.","Redeploy the supervisor with the corrected tuning config."],"exampleFix":"// before\n\"tuningConfig\": { \"type\": \"kinesis\", \"maxRecordsPerPoll\": 10000 }\n// after\n\"tuningConfig\": { \"type\": \"kinesis\", \"maxBytesPerPoll\": 4194304 }","handlingStrategy":"validation","validationCode":"Object node = tuningConfigNode.get(\"maxRecordsPerPoll\");\nif (node != null) throw new IllegalArgumentException(\"Use maxBytesPerPoll instead\");","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Replace maxRecordsPerPoll in all stored specs","Compute byte equivalents from average record size","Keep IaC modules updated with current tuning config schema"],"tags":["kinesis","deprecation","tuning-config"],"backgroundTag":"deprecated-api-usage","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"}