Fixed small bug with var init

Signed-off-by: Athish Pranav D <[email protected]>

Author: Athishpranav2003

plugins/out_kinesis_streams/kinesis.c

@@ -113,11 +113,6 @@ static int cb_kinesis_init(struct flb_output_instance *ins,
         ctx->custom_endpoint = FLB_FALSE;
     }
 
-    tmp = flb_output_get_property("port", ins);
-    if (tmp) {
-        ctx->port = tmp;
-    }
-
     tmp = flb_output_get_property("sts_endpoint", ins);
     if (tmp) {
         ctx->sts_endpoint = (char *) tmp;
@@ -446,8 +441,8 @@ static struct flb_config_map config_map[] = {
     },
 
     {
-     FLB_CONFIG_MAP_INT, "port", 443,
-     0, FLB_FALSE, 0,
+     FLB_CONFIG_MAP_INT, "port", "443",
+     0, FLB_TRUE, offsetof(struct flb_kinesis, port),
      "Specify a port for the Kinesis API"
     },
 

plugins/out_kinesis_streams/kinesis.h

@@ -89,6 +89,7 @@ struct flb_kinesis {
     const char *role_arn;
     const char *log_key;
     const char *external_id;
+    const int port;
     int retry_requests;
     char *sts_endpoint;
     int custom_endpoint;