From 3e5bbc6ab6deb0bfbb9da99ffd59acd2ddac8027 Mon Sep 17 00:00:00 2001 From: Takahiro Yamashita Date: Sat, 5 Aug 2023 11:45:56 +0900 Subject: [PATCH 1/2] out_kinesis_firefose: fix typo Signed-off-by: Takahiro Yamashita --- plugins/out_kinesis_firehose/firehose_api.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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", From bff5619754d08932b59bbf91b656389da1d9dc15 Mon Sep 17 00:00:00 2001 From: Takahiro Yamashita Date: Sat, 5 Aug 2023 11:46:09 +0900 Subject: [PATCH 2/2] out_kinesis_streams: fix typo Signed-off-by: Takahiro Yamashita --- plugins/out_kinesis_streams/kinesis_api.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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",