Not respecting `port` parameter? #76

joshuar · 2018-04-26T05:11:10Z

Version: logstash-output-rabbitmq (5.1.1)
Operating System: Linux (Fedora 27)
Config File (if you have sensitive info, please remove it):

input {
    stdin { }
}

output {
    rabbitmq {
        host => ["localhost"]
        key => "whatevs"
        persistent => true
        port => 35007
        vhost => "logstash"
        exchange => ""
        exchange_type => "fanout"
    }
}

Sample Data: N/A
Steps to Reproduce:

I'm starting up a test RabbitMQ install with:

docker run --rm -ti --hostname my-rabbit --name some-rabbit -p 35007:35007 -e RABBITMQ_NODE_PORT=35007 rabbitmq:3

Note that I'm using a custom port, 35007. When I start Logstash with the above configuration, it still tries to connect on port 5672:

Sending Logstash's logs to /home/joshua/Documents/Support/217376/logstash-6.2.4/logs which is now configured via log4j2.properties
[2018-04-26T15:08:15,064][INFO ][logstash.modules.scaffold] Initializing module {:module_name=>"netflow", :directory=>"/home/joshua/Documents/Support/217376/logstash-6.2.4/modules/netflow/configuration"}
[2018-04-26T15:08:15,075][DEBUG][logstash.plugins.registry] Adding plugin to the registry {:name=>"netflow", :type=>:modules, :class=>#<LogStash::Modules::Scaffold:0x73e91c6d @module_name="netflow", @directory="/home/joshua/Documents/Support/217376/logstash-6.2.4/modules/netflow/configuration", @kibana_version_parts=["6", "0", "0"]>}
[2018-04-26T15:08:15,087][INFO ][logstash.modules.scaffold] Initializing module {:module_name=>"fb_apache", :directory=>"/home/joshua/Documents/Support/217376/logstash-6.2.4/modules/fb_apache/configuration"}
[2018-04-26T15:08:15,088][DEBUG][logstash.plugins.registry] Adding plugin to the registry {:name=>"fb_apache", :type=>:modules, :class=>#<LogStash::Modules::Scaffold:0x4e41441b @module_name="fb_apache", @directory="/home/joshua/Documents/Support/217376/logstash-6.2.4/modules/fb_apache/configuration", @kibana_version_parts=["6", "0", "0"]>}
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] -------- Logstash Settings (* means modified) ---------
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] node.name: "ludicra"
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] *path.config: "../logstash.conf"
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] path.data: "/home/joshua/Documents/Support/217376/logstash-6.2.4/data"
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] modules.cli: []
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] modules: []
[2018-04-26T15:08:15,535][DEBUG][logstash.runner          ] modules_setup: false
[2018-04-26T15:08:15,536][DEBUG][logstash.runner          ] config.test_and_exit: false
[2018-04-26T15:08:15,536][DEBUG][logstash.runner          ] config.reload.automatic: false
[2018-04-26T15:08:15,536][DEBUG][logstash.runner          ] config.reload.interval: 3000000000
[2018-04-26T15:08:15,536][DEBUG][logstash.runner          ] config.support_escapes: false
[2018-04-26T15:08:15,536][DEBUG][logstash.runner          ] metric.collect: true
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.id: "main"
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.system: false
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.workers: 4
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.output.workers: 1
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.batch.size: 125
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.batch.delay: 50
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.unsafe_shutdown: false
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.java_execution: false
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] pipeline.reloadable: true
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] path.plugins: []
[2018-04-26T15:08:15,537][DEBUG][logstash.runner          ] config.debug: false
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] *log.level: "debug" (default: "info")
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] version: false
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] help: false
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] log.format: "plain"
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] http.host: "127.0.0.1"
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] http.port: 9600..9700
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] http.environment: "production"
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] queue.type: "memory"
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] queue.drain: false
[2018-04-26T15:08:15,538][DEBUG][logstash.runner          ] queue.page_capacity: 67108864
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] queue.max_bytes: 1073741824
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] queue.max_events: 0
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] queue.checkpoint.acks: 1024
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] queue.checkpoint.writes: 1024
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] queue.checkpoint.interval: 1000
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] dead_letter_queue.enable: false
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] dead_letter_queue.max_bytes: 1073741824
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] slowlog.threshold.warn: -1
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] slowlog.threshold.info: -1
[2018-04-26T15:08:15,539][DEBUG][logstash.runner          ] slowlog.threshold.debug: -1
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] slowlog.threshold.trace: -1
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] keystore.classname: "org.logstash.secret.store.backend.JavaKeyStore"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] keystore.file: "/home/joshua/Documents/Support/217376/logstash-6.2.4/config/logstash.keystore"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] path.queue: "/home/joshua/Documents/Support/217376/logstash-6.2.4/data/queue"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] path.dead_letter_queue: "/home/joshua/Documents/Support/217376/logstash-6.2.4/data/dead_letter_queue"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] path.settings: "/home/joshua/Documents/Support/217376/logstash-6.2.4/config"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] path.logs: "/home/joshua/Documents/Support/217376/logstash-6.2.4/logs"
[2018-04-26T15:08:15,540][DEBUG][logstash.runner          ] --------------- Logstash Settings -------------------
[2018-04-26T15:08:15,642][WARN ][logstash.config.source.multilocal] Ignoring the 'pipelines.yml' file because modules or command line options are specified
[2018-04-26T15:08:15,747][DEBUG][logstash.agent           ] Setting up metric collection
[2018-04-26T15:08:15,876][DEBUG][logstash.instrument.periodicpoller.os] Starting {:polling_interval=>5, :polling_timeout=>120}
[2018-04-26T15:08:16,024][DEBUG][logstash.instrument.periodicpoller.cgroup] Error, cannot retrieve cgroups information {:exception=>"NoMethodError", :message=>"undefined method `[]' for nil:NilClass"}
[2018-04-26T15:08:16,270][DEBUG][logstash.instrument.periodicpoller.jvm] Starting {:polling_interval=>5, :polling_timeout=>120}
[2018-04-26T15:08:16,507][DEBUG][logstash.instrument.periodicpoller.jvm] collector name {:name=>"ParNew"}
[2018-04-26T15:08:16,515][DEBUG][logstash.instrument.periodicpoller.jvm] collector name {:name=>"ConcurrentMarkSweep"}
[2018-04-26T15:08:16,644][DEBUG][logstash.instrument.periodicpoller.persistentqueue] Starting {:polling_interval=>5, :polling_timeout=>120}
[2018-04-26T15:08:16,667][DEBUG][logstash.instrument.periodicpoller.deadletterqueue] Starting {:polling_interval=>5, :polling_timeout=>120}
[2018-04-26T15:08:16,797][INFO ][logstash.runner          ] Starting Logstash {"logstash.version"=>"6.2.4"}
[2018-04-26T15:08:16,852][DEBUG][logstash.agent           ] Starting agent
[2018-04-26T15:08:16,932][DEBUG][logstash.agent           ] Starting puma
[2018-04-26T15:08:16,969][DEBUG][logstash.agent           ] Trying to start WebServer {:port=>9600}
[2018-04-26T15:08:17,123][DEBUG][logstash.api.service     ] [api-service] start
[2018-04-26T15:08:17,159][DEBUG][logstash.config.source.local.configpathloader] Skipping the following files while reading config since they don't match the specified glob pattern {:files=>["/home/joshua/Documents/Support/217376/logstash-6.2.4", "/home/joshua/Documents/Support/217376/rabbitmq.log"]}
[2018-04-26T15:08:17,199][DEBUG][logstash.config.source.local.configpathloader] Reading config file {:config_file=>"/home/joshua/Documents/Support/217376/logstash.conf"}
[2018-04-26T15:08:17,382][DEBUG][logstash.agent           ] Converging pipelines state {:actions_count=>1}
[2018-04-26T15:08:17,430][DEBUG][logstash.agent           ] Executing action {:action=>LogStash::PipelineAction::Create/pipeline_id:main}
[2018-04-26T15:08:17,875][INFO ][logstash.agent           ] Successfully started Logstash API endpoint {:port=>9600}
[2018-04-26T15:08:19,775][DEBUG][logstash.plugins.registry] On demand adding plugin to the registry {:name=>"stdin", :type=>"input", :class=>LogStash::Inputs::Stdin}
[2018-04-26T15:08:20,211][DEBUG][logstash.plugins.registry] On demand adding plugin to the registry {:name=>"line", :type=>"codec", :class=>LogStash::Codecs::Line}
[2018-04-26T15:08:20,273][DEBUG][logstash.codecs.line     ] config LogStash::Codecs::Line/@id = "line_c454ebc0-5c8e-40ff-8146-e684fe1f0a07"
[2018-04-26T15:08:20,275][DEBUG][logstash.codecs.line     ] config LogStash::Codecs::Line/@enable_metric = true
[2018-04-26T15:08:20,275][DEBUG][logstash.codecs.line     ] config LogStash::Codecs::Line/@charset = "UTF-8"
[2018-04-26T15:08:20,277][DEBUG][logstash.codecs.line     ] config LogStash::Codecs::Line/@delimiter = "\n"
[2018-04-26T15:08:20,362][DEBUG][logstash.inputs.stdin    ] config LogStash::Inputs::Stdin/@id = "c142e6e2bc1a4de5641f94c859fc9172e7f55f84d836657f095dc3025a2d5f1c"
[2018-04-26T15:08:20,362][DEBUG][logstash.inputs.stdin    ] config LogStash::Inputs::Stdin/@enable_metric = true
[2018-04-26T15:08:20,376][DEBUG][logstash.inputs.stdin    ] config LogStash::Inputs::Stdin/@codec = <LogStash::Codecs::Line id=>"line_c454ebc0-5c8e-40ff-8146-e684fe1f0a07", enable_metric=>true, charset=>"UTF-8", delimiter=>"\n">
[2018-04-26T15:08:20,380][DEBUG][logstash.inputs.stdin    ] config LogStash::Inputs::Stdin/@add_field = {}
[2018-04-26T15:08:20,695][DEBUG][logstash.plugins.registry] On demand adding plugin to the registry {:name=>"rabbitmq", :type=>"output", :class=>LogStash::Outputs::RabbitMQ}
[2018-04-26T15:08:20,825][DEBUG][logstash.plugins.registry] On demand adding plugin to the registry {:name=>"json", :type=>"codec", :class=>LogStash::Codecs::JSON}
[2018-04-26T15:08:20,860][DEBUG][logstash.codecs.json     ] config LogStash::Codecs::JSON/@id = "json_2977da76-afed-477b-9d75-d62021aa64ef"
[2018-04-26T15:08:20,886][DEBUG][logstash.codecs.json     ] config LogStash::Codecs::JSON/@enable_metric = true
[2018-04-26T15:08:20,887][DEBUG][logstash.codecs.json     ] config LogStash::Codecs::JSON/@charset = "UTF-8"
[2018-04-26T15:08:20,966][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@host = ["localhost"]
[2018-04-26T15:08:20,966][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@key = "secure_log"
[2018-04-26T15:08:20,967][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@persistent = true
[2018-04-26T15:08:20,967][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@port = 35007
[2018-04-26T15:08:20,967][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@vhost = "logstash"
[2018-04-26T15:08:20,967][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@exchange = ""
[2018-04-26T15:08:20,967][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@exchange_type = "fanout"
[2018-04-26T15:08:20,968][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@id = "d0af37538727094bad9fb7a925d1cd0b8d09dc7e8281c8a89a720628e0032478"
[2018-04-26T15:08:20,968][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@enable_metric = true
[2018-04-26T15:08:20,969][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@codec = <LogStash::Codecs::JSON id=>"json_2977da76-afed-477b-9d75-d62021aa64ef", enable_metric=>true, charset=>"UTF-8">
[2018-04-26T15:08:20,969][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@workers = 1
[2018-04-26T15:08:20,969][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@user = "guest"
[2018-04-26T15:08:20,972][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@password = <password>
[2018-04-26T15:08:20,973][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@ssl_version = "TLSv1.2"
[2018-04-26T15:08:20,988][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@automatic_recovery = true
[2018-04-26T15:08:20,990][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@connect_retry_interval = 1
[2018-04-26T15:08:20,991][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@passive = false
[2018-04-26T15:08:20,992][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@arguments = {}
[2018-04-26T15:08:20,994][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@durable = true
[2018-04-26T15:08:21,002][DEBUG][logstash.outputs.rabbitmq] config LogStash::Outputs::RabbitMQ/@message_properties = {}
[2018-04-26T15:08:21,234][INFO ][logstash.pipeline        ] Starting pipeline {:pipeline_id=>"main", "pipeline.workers"=>4, "pipeline.batch.size"=>125, "pipeline.batch.delay"=>50}
[2018-04-26T15:08:21,384][DEBUG][logstash.instrument.periodicpoller.cgroup] Error, cannot retrieve cgroups information {:exception=>"NoMethodError", :message=>"undefined method `[]' for nil:NilClass"}
[2018-04-26T15:08:21,418][DEBUG][logstash.outputs.rabbitmq] Connecting to RabbitMQ. Settings: {:vhost=>"logstash", :hosts=>["localhost"], :port=>35007, :user=>"guest", :automatic_recovery=>true, :pass=>"guest", :timeout=>0, :heartbeat=>0}
[2018-04-26T15:08:21,728][ERROR][logstash.outputs.rabbitmq] RabbitMQ connection error, will retry. {:error_message=>"Connection to localhost:5672 refused", :exception=>"MarchHare::ConnectionRefused", :backtrace=>["/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:505:in `converting_rjc_exceptions_to_ruby'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:541:in `new_connection_impl'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:534:in `build_new_connection'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:157:in `initialize'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:127:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare.rb:24:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-mixin-rabbitmq_connection-5.0.2-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:201:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-mixin-rabbitmq_connection-5.0.2-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:138:in `connect!'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-output-rabbitmq-5.1.1-java/lib/logstash/outputs/rabbitmq.rb:47:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/output_delegator_strategies/shared.rb:9:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/output_delegator.rb:42:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:342:in `register_plugin'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:353:in `block in register_plugins'", "org/jruby/RubyArray.java:1734:in `each'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:353:in `register_plugins'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:730:in `maybe_setup_out_plugins'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:363:in `start_workers'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:290:in `run'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:250:in `block in start'"]}
[2018-04-26T15:08:21,830][DEBUG][logstash.instrument.periodicpoller.jvm] collector name {:name=>"ParNew"}
[2018-04-26T15:08:21,833][DEBUG][logstash.instrument.periodicpoller.jvm] collector name {:name=>"ConcurrentMarkSweep"}
[2018-04-26T15:08:22,763][DEBUG][logstash.outputs.rabbitmq] Connecting to RabbitMQ. Settings: {:vhost=>"logstash", :hosts=>["localhost"], :port=>35007, :user=>"guest", :automatic_recovery=>true, :pass=>"guest", :timeout=>0, :heartbeat=>0}
[2018-04-26T15:08:22,768][ERROR][logstash.outputs.rabbitmq] RabbitMQ connection error, will retry. {:error_message=>"Connection to localhost:5672 refused", :exception=>"MarchHare::ConnectionRefused", :backtrace=>["/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:505:in `converting_rjc_exceptions_to_ruby'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:541:in `new_connection_impl'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:534:in `build_new_connection'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:157:in `initialize'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare/session.rb:127:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/march_hare-3.1.1-java/lib/march_hare.rb:24:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-mixin-rabbitmq_connection-5.0.2-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:201:in `connect'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-mixin-rabbitmq_connection-5.0.2-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:138:in `connect!'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/vendor/bundle/jruby/2.3.0/gems/logstash-output-rabbitmq-5.1.1-java/lib/logstash/outputs/rabbitmq.rb:47:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/output_delegator_strategies/shared.rb:9:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/output_delegator.rb:42:in `register'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:342:in `register_plugin'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:353:in `block in register_plugins'", "org/jruby/RubyArray.java:1734:in `each'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:353:in `register_plugins'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:730:in `maybe_setup_out_plugins'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:363:in `start_workers'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:290:in `run'", "/home/joshua/Documents/Support/217376/logstash-6.2.4/logstash-core/lib/logstash/pipeline.rb:250:in `block in start'"]}
^C[2018-04-26T15:08:23,143][WARN ][logstash.runner          ] SIGINT received. Shutting down.
^C[2018-04-26T15:08:23,305][FATAL][logstash.runner          ] SIGINT received. Terminating immediately..

Am I missing something?

The text was updated successfully, but these errors were encountered:

jsvd · 2018-04-30T10:58:48Z

This seems to be the way the underlying library we use (march_hare) works: if you specify a list of hosts then the port option is ignored. However in this plugin we always pass a list, even if it's a list of 1, so the port is always ignored...

We should likely just remove this port option. Currently the users can pass a list of "host" strings when the port is 5672, or "host:port" strings when the port is different than 5672.

joshuar · 2018-04-30T23:18:22Z

Ah cool! Thanks @jsvd! I didn't realise a host:port combo would work as well. That works for me. The doc examples are all just host strings. So possibly a doc update as well required?

seandilda · 2019-01-23T13:48:37Z

There's a known issue with march_hare (ruby-amqp/march_hare#133) that causes localhost:5672 to always show up in connection errors, even if that's not where its connecting.

If anyone else sees this, ignore the error message and use tcpdump to verify the traffic is going where you want.

mikearruda · 2019-07-12T19:47:35Z

@jsvd Thank you so much! "host:port" is working for me now.

Ricaz · 2019-10-10T07:00:38Z

I had the same problem with the RabbitMQ input plugin because I had forgotten to specify ssl => true. It would fail to initiate a handshake, but the logs only stated it failed to connect to the default address (localhost:5672, not mq.example.org:5671 as I specified).

jsvd added the bug label Apr 30, 2018

mikearruda mentioned this issue Jul 12, 2019

When connecting using options other than :host and :port, error messages always refer to default host and port ruby-amqp/march_hare#133

Closed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Not respecting `port` parameter? #76

Not respecting `port` parameter? #76

joshuar commented Apr 26, 2018

jsvd commented Apr 30, 2018

joshuar commented Apr 30, 2018

seandilda commented Jan 23, 2019

mikearruda commented Jul 12, 2019

Ricaz commented Oct 10, 2019

Not respecting port parameter? #76

Not respecting port parameter? #76

Comments

joshuar commented Apr 26, 2018

jsvd commented Apr 30, 2018

joshuar commented Apr 30, 2018

seandilda commented Jan 23, 2019

mikearruda commented Jul 12, 2019

Ricaz commented Oct 10, 2019

Not respecting `port` parameter? #76

Not respecting `port` parameter? #76