# Logstash support redis cluster

**URL:** https://discuss.elastic.co/t/logstash-support-redis-cluster/213492
**Category:** Logstash
**Created:** [January 1, 2020, 3:42pm UTC](https://discuss.elastic.co/t/logstash-support-redis-cluster/213492 "2020-01-01T15:42:43Z")
**Posts on this page:** 2
**Page:** 1

<div class="post-metadata">

### Author: ![mingbei.xu](https://avatars.discourse-cdn.com/v4/letter/m/73ab20/32.png) [@mingbei.xu](https://discuss.elastic.co/u/mingbei.xu)
#### Post date: [January 1, 2020, 3:42pm UTC](https://discuss.elastic.co/t/logstash-support-redis-cluster/213492/1 "2020-01-01T15:42:44Z")

</div>

1、update redis-rb version to 4.1.3  
2、update /vendor/bundle/jruby/2.3.0/gemslogstash-output-redis-4.0.4/lib /logstash/outputs/redis.rb

```auto
#if not @current_port
# @current_port = @port
#end

#params = {
# :host => @current_host,
# :port => @current_port,
# :timeout => @timeout,
# :db => @db
#}
#@logger.debug("connection params", params)

if @cluster
  Redis.new(cluster:@host)
else 
  @current_host, @current_port = @host[@host_idx].split(':')
  @host_idx = @host_idx + 1 >= @host.length ? 0 : @host_idx + 1
  if not @current_port
    @current_port = @port
  end

  params = {
    :host => @current_host,
    :port => @current_port,
    :timeout => @timeout,
    :db => @db
  }

  if @password
    params[:password] = @password.value
  end
  @logger.debug("connection params", params)
  Redis.new(params)
end

```

3、output info：  
output {  
if [logtype]=="redis" {  
redis {  
codec =\> plain {  
format =\> "%{startDate} %{startHour} %{responseTime} %{apiCode} %{apiType} %{uid} %{success}"  
}  
data\_type =\> "list"  
key =\> "jdbc\_sample\_test"  
host =\> ["redis://@172.24.5.244:7000","redis://@172.24.5.244:7001","redis://@172.24.5.244:7002","redis://@172.24.5.245:7000","redis://@172.24.5.245:7001","redis://@172.24.5.245:7002"]  
batch =\> true  
cluster =\> true  
}  
}  
}

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)
#### Post date: [January 29, 2020, 3:42pm UTC](https://discuss.elastic.co/t/logstash-support-redis-cluster/213492/2 "2020-01-29T15:42:54Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.