{"record":{"id":"de1c70d3fc07e64e","repo":"apache/druid","slug":"the-recordbuffersize-config-property-of-the-kine","errorCode":null,"errorMessage":"The 'recordBufferSize' config property of the kinesis tuning config has been deprecated. Please use 'recordBufferSizeBytes'.","messagePattern":"The 'recordBufferSize' config property of the kinesis tuning config has been deprecated\\. Please use 'recordBufferSizeBytes'\\.","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":99,"sourceCode":"        supervisorId,\n        taskResource,\n        dataSchema,\n        tuningConfig,\n        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)","sourceCodeStart":81,"sourceCodeEnd":117,"githubUrl":"https://github.com/apache/druid/blob/9b90983fd291f26935af934383ce360473179e4d/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTask.java#L81-L117","documentation":"KinesisIndexTask.runTask() logs a deprecation warning when the tuning config's recordBufferSize field was explicitly set (getRecordBufferSizeConfigured() != null). The byte-based recordBufferSizeBytes property replaces the record-count-based property. The task still runs; this is advisory only.","triggerScenarios":"Submitting or running a Kinesis indexing task whose tuning config contains the deprecated 'recordBufferSize' property.","commonSituations":"Older JSON specs copied from pre-upgrade templates; docs or tooling still emitting recordBufferSize after upgrade to the bytes-based tuning config.","solutions":["Replace 'recordBufferSize' with 'recordBufferSizeBytes' in the tuning config (value in bytes instead of records).","Convert the old record count to an approximate byte budget given your average record size.","Update stored spec templates and any automation that generates supervisor specs.","Re-submit/re-create the supervisor so the new tuning config takes effect."],"exampleFix":"// before\n\"tuningConfig\": { \"type\": \"kinesis\", \"recordBufferSize\": 1000 }\n// after\n\"tuningConfig\": { \"type\": \"kinesis\", \"recordBufferSizeBytes\": 1048576 }","handlingStrategy":"validation","validationCode":"if (tuningConfig instanceof KinesisIndexTaskClient) { /* check spec JSON */ }\nObject node = tuningConfigNode.get(\"recordBufferSize\");\nif (node != null) throw new IllegalArgumentException(\"Use recordBufferSizeBytes instead\");","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Lint submitted specs for deprecated kinesis tuning fields","Migrate templates to recordBufferSizeBytes after upgrade","Track Druid upgrade notes for renamed config properties"],"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"}