Missing error aws (#9048)

2 files changed, 7 insertions, 1 deletions

diff --git a/exporting/aws_kinesis/aws_kinesis.c b/exporting/aws_kinesis/aws_kinesis.c
index a32d805d66..cc0da13062 100644
--- a/exporting/aws_kinesis/aws_kinesis.c
+++ b/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,
diff --git a/exporting/read_config.c b/exporting/read_config.c
index c7cd46c3cf..21769e87a5 100644
--- a/exporting/read_config.c
+++ b/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", ""));
         }