diff --git a/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json b/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json
index 8038de78..67c4e157 100644
--- a/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json
+++ b/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json
@@ -54,7 +54,12 @@
           },
           "message_tag_name": {
             "type": "string"
-          }
+          },
+          "timeout": {
+          "type": "integer",
+          "minimum": 1,
+          "err_message": "[telemetry-endpoint - timeout] attribute should be an integer greater than 0"
+        }
         },
         "required": [
           "host",
diff --git a/plugins/fluentd_telemetry_plugin/src/streamer.py b/plugins/fluentd_telemetry_plugin/src/streamer.py
index 9720b9e2..774977b2 100644
--- a/plugins/fluentd_telemetry_plugin/src/streamer.py
+++ b/plugins/fluentd_telemetry_plugin/src/streamer.py
@@ -51,6 +51,9 @@ def __init__(self, conf_parser):
         self.telem_parser = TelemetryParser(self.config_parser, self.streaming_metrics_mgr,
                                             self.last_streamed_data_sample_per_endpoint,
                                             self.attributes_mngr)
+        self.init_streaming_attributes()
+
+    def init_streaming_attributes(self):
         self.attributes_mngr.init_streaming_attributes(self.telem_parser,
                                                        self.ufm_telemetry_endpoints, self.config_parser)