change redis sentinel config format

Author: TinOo512

lib/logstash/inputs/redis.rb

@@ -28,7 +28,7 @@ module LogStash module Inputs class Redis < LogStash::Inputs::Threadable
   # The hostname of your Redis server.
   config :host, :validate => :string, :default => "127.0.0.1"
 
-  # The hostnames of your sentinel servers.
+  # The hostnames and ports of your sentinel servers.
   config :sentinel_hosts, :validate => :array
 
   # The connection URLs of your cluster servers.
@@ -37,16 +37,13 @@ module LogStash module Inputs class Redis < LogStash::Inputs::Threadable
   # The port to connect on.
   config :port, :validate => :number, :default => 6379
 
-  # The sentinel port to connect on.
-  config :sentinel_port, :validate => :number, :default => 26379
-
   # The name of the sentinel master to connect to.
   config :sentinel_master_name, :validate => :string, :default => "mymaster"
 
   # SSL
   config :ssl, :validate => :boolean, :default => false
 
-  # The unix socket path to connect on. Will override host and port and sentinel_hosts and sentinel_port and cluster_hosts if defined.
+  # The unix socket path to connect on. Will override host and port and sentinel_hosts and cluster_hosts if defined.
   # There is no unix socket path by default.
   config :path, :validate => :string
 
@@ -81,7 +78,7 @@ def register
     elsif !@cluster_hosts.nil?
       @redis_url = "#{@password}@#{@cluster_hosts.map { |h| "#{h}" }.join(',')}/#{@db}"
     elsif !@sentinel_hosts.nil?
-      @redis_url = "redis://#{@password}@#{@sentinel_master_name}:#{@port}/#{@db}"
+      @redis_url = "redis://#{@password}@#{@sentinel_master_name}/#{@db}"
     else
       @redis_url = "redis://#{@password}@#{@host}:#{@port}/#{@db}"
     end
@@ -141,7 +138,10 @@ def redis_params
           :nodes => cluster_hosts,
         }
       elsif !@sentinel_hosts.nil?
-        hosts = @sentinel_hosts.map { |sentinel_host| { host: sentinel_host, port: @sentinel_port } }
+        hosts = @sentinel_hosts.map do |sentinel_host|
+          host, port = sentinel_host.split(':', 2)
+          { host: host, port: port ? port.to_i : 26379 }
+        end
         params = {
           :name => @sentinel_master_name,
           :sentinels => hosts,