fluent/fluentd · error · Fluent::ConfigError

Invalid rpc_endpoint: #{endpoint}

Error message

Invalid rpc_endpoint: #{endpoint}

What it means

Error "Invalid rpc_endpoint: #{endpoint}" thrown in fluent/fluentd.

Source

Thrown at lib/fluent/rpc.rb:24

#    You may obtain a copy of the License at
#
#        http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS,
#    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#    See the License for the specific language governing permissions and
#    limitations under the License.
#

require 'webrick'

module Fluent
  module RPC
    class Server
      def initialize(endpoint, log)
        m = endpoint.match(/^\[?(?<host>[0-9a-zA-Z:\-\.]+)\]?:(?<port>[0-9]+)$/)
        raise Fluent::ConfigError, "Invalid rpc_endpoint: #{endpoint}" unless m
        @bind = m[:host]
        @port = m[:port]
        @log = log

        @server = WEBrick::HTTPServer.new(
          BindAddress: @bind,
          Port: @port,
          Logger: WEBrick::Log.new(STDERR, WEBrick::Log::FATAL),
          AccessLog: [],
        )
      end

      def mount(path, servlet, *args)
        @server.mount(path, servlet, *args)
        @log.debug "register #{path} RPC servlet"
      end

      def mount_proc(path, &block)

View on GitHub (pinned to dd45c6e18d)

When it happens

Trigger: Thrown at lib/fluent/rpc.rb:24 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of fluent/fluentd@dd45c6e18d (2026-08-21). Data as JSON: /api/errors/43c0e2eb6ec37adc. Report an issue: GitHub.