{"record":{"id":"94883d5b4efa6ffd","repo":"fluent/fluentd","slug":"missing-type-parameter-on-source-directive","errorCode":null,"errorMessage":"Missing '@type' parameter on <source> directive","messagePattern":"Missing '@type' parameter on <source> directive","errorType":"exception","errorClass":"Fluent::ConfigError","httpStatus":null,"severity":"error","filePath":"lib/fluent/root_agent.rb","lineNumber":197,"sourceCode":"      }\n      # Call 'configure' here to avoid 'label not found'\n      label_configs.each { |name, e| @labels[name].configure(e) }\n      setup_error_label(error_label_config) if error_label_config\n\n      super\n\n      setup_source_only_buffer_agent if @source_only_mode.enabled?\n\n      # initialize <source> elements\n      if @without_source\n        log.info :worker0, \"'--without-source' is applied. Ignore <source> sections\"\n      else\n        conf.elements(name: 'source').each { |e|\n          if !Fluent::Engine.supervisor_mode && e.for_another_worker?\n            next\n          end\n          type = e['@type']\n          raise ConfigError, \"Missing '@type' parameter on <source> directive\" unless type\n          add_source(type, e)\n        }\n      end\n    end\n\n    def setup_error_label(e)\n      error_label = add_label(ERROR_LABEL)\n      error_label.configure(e)\n      @error_collector = error_label.event_router\n    end\n\n    def setup_source_only_buffer_agent(flush: false)\n      @source_only_buffer_agent = SourceOnlyBufferAgent.new(log: log, system_config: Fluent::Engine.system_config)\n      @source_only_buffer_agent.configure(flush: flush)\n    end\n\n    def cleanup_source_only_buffer_agent\n      @source_only_buffer_agent&.cleanup","sourceCodeStart":179,"sourceCodeEnd":215,"githubUrl":"https://github.com/fluent/fluentd/blob/dd45c6e18dc7be33b5e5a0f0767bf46307ff5626/lib/fluent/root_agent.rb#L179-L215","documentation":"Error \"Missing '@type' parameter on <source> directive\" thrown in fluent/fluentd.","triggerScenarios":"Thrown at lib/fluent/root_agent.rb:197 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":[],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"dd45c6e18dc7be33b5e5a0f0767bf46307ff5626","analyzedAt":"2026-08-21T16:22:07.332Z","schemaVersion":2},"datasetVersion":"2026-08-21T18:17:14.833Z"}