Browse Source

Missing error aws (#9048)

thiagoftsm 4 years ago
parent
commit
a938e769b6
2 changed files with 7 additions and 1 deletions
  1. 5 0
      exporting/aws_kinesis/aws_kinesis.c
  2. 2 1
      exporting/read_config.c

+ 5 - 0
exporting/aws_kinesis/aws_kinesis.c

@@ -68,6 +68,11 @@ int init_aws_kinesis_instance(struct instance *instance)
     struct aws_kinesis_specific_data *connector_specific_data = callocz(1, sizeof(struct aws_kinesis_specific_data));
     instance->connector_specific_data = (void *)connector_specific_data;
 
+    if (!strcmp(connector_specific_config->stream_name, "")) {
+        error("stream name is a mandatory Kinesis parameter but it is not configured");
+        return 1;
+    }
+
     kinesis_init(
         (void *)connector_specific_data,
         instance->config.destination,

+ 2 - 1
exporting/read_config.c

@@ -396,7 +396,8 @@ struct engine *read_exporting_config()
 
             tmp_instance->config.connector_specific_config = connector_specific_config;
 
-            connector_specific_config->stream_name = strdupz(exporter_get(instance_name, "stream name", "netdata"));
+            connector_specific_config->stream_name = strdupz(exporter_get(instance_name, "stream name", ""));
+
             connector_specific_config->auth_key_id = strdupz(exporter_get(instance_name, "aws_access_key_id", ""));
             connector_specific_config->secure_key = strdupz(exporter_get(instance_name, "aws_secret_access_key", ""));
         }