Skip to content

Commit 098d944

Browse files
Fixed small bug with var init
Signed-off-by: Athish Pranav D <[email protected]>
1 parent 2ff1247 commit 098d944

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

plugins/out_kinesis_streams/kinesis.c

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -113,11 +113,6 @@ static int cb_kinesis_init(struct flb_output_instance *ins,
113113
ctx->custom_endpoint = FLB_FALSE;
114114
}
115115

116-
tmp = flb_output_get_property("port", ins);
117-
if (tmp) {
118-
ctx->port = tmp;
119-
}
120-
121116
tmp = flb_output_get_property("sts_endpoint", ins);
122117
if (tmp) {
123118
ctx->sts_endpoint = (char *) tmp;
@@ -446,7 +441,7 @@ static struct flb_config_map config_map[] = {
446441
},
447442

448443
{
449-
FLB_CONFIG_MAP_INT, "port", 443,
444+
FLB_CONFIG_MAP_INT, "port", "443",
450445
0, FLB_FALSE, 0,
451446
"Specify a port for the Kinesis API"
452447
},

plugins/out_kinesis_streams/kinesis.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,7 @@ struct flb_kinesis {
8989
const char *role_arn;
9090
const char *log_key;
9191
const char *external_id;
92+
const int port;
9293
int retry_requests;
9394
char *sts_endpoint;
9495
int custom_endpoint;

0 commit comments

Comments
 (0)