diff --git a/plugins/out_kinesis_firehose/firehose_api.c b/plugins/out_kinesis_firehose/firehose_api.c
index 9e3c1152c76..5c2f0c2f9b0 100644
--- a/plugins/out_kinesis_firehose/firehose_api.c
+++ b/plugins/out_kinesis_firehose/firehose_api.c
@@ -741,7 +741,7 @@ static int process_api_response(struct flb_firehose *ctx,
                             (strncmp(response_val.via.str.ptr,
                                     ERR_CODE_SERVICE_UNAVAILABLE, 27) == 0)) {
                                         throughput_exceeded = FLB_TRUE;
-                                        flb_plg_error(ctx->ins, "Thoughput limits may have been exceeded, %s",
+                                        flb_plg_error(ctx->ins, "Throughput limits may have been exceeded, %s",
                                                       ctx->delivery_stream);
                         }
                         flb_plg_debug(ctx->ins, "Record %i failed with err_code=%.*s",
diff --git a/plugins/out_kinesis_streams/kinesis_api.c b/plugins/out_kinesis_streams/kinesis_api.c
index 95c500b5b68..664e4fe4dad 100644
--- a/plugins/out_kinesis_streams/kinesis_api.c
+++ b/plugins/out_kinesis_streams/kinesis_api.c
@@ -771,7 +771,7 @@ static int process_api_response(struct flb_kinesis *ctx,
                             (strncmp(response_val.via.str.ptr,
                                     ERR_CODE_EXCEEDED_THROUGHPUT, 38) == 0)) {
                                         throughput_exceeded = FLB_TRUE;
-                                        flb_plg_error(ctx->ins, "Thoughput limits may have been exceeded, %s",
+                                        flb_plg_error(ctx->ins, "Throughput limits may have been exceeded, %s",
                                                       ctx->stream_name);
                         }
                         flb_plg_debug(ctx->ins, "Record %i failed with err_code=%.*s",