The Redis plugin is a collection of connectors that are used to interact with a Redis cluster.
The Redis Sink Connector is used to write data from Kafka to a Redis cache.
The Redis hosts to connect to.
Importance: High
Type: List
Default Value: [127.0.0.1:6379]
The client mode to use when interacting with the Redis cluster.
Importance: Medium
Type: String
Default Value: STANDALONE
Validator: Matches: STANDALONE, CLUSTER, SENTINEL, MASTER_SLAVE
Setup connection name during connection init CLIENT SETNAME command
Importance: Medium
Type: String
Default Value: kafka connector
Validator:
Redis database to connect to.
Importance: Medium
Type: Int
Default Value: 1
use ssl to connect redis.
Importance: Medium
Type: Boolean
Default Value: false
Password used to connect to Redis.
Importance: Medium
Type: Password
Default Value: [hidden]
The amount of time in milliseconds before an operation is marked as timed out.
Importance: Medium
Type: Long
Default Value: 10000
Validator: [100,...]
If pooled connection not used for a timeout time
and current connections amount bigger than minimum idle connections pool size,
then it will closed and removed from pool.
Importance: Medium
Type: Long
Default Value: 10000
Validator: [100,...]
Timeout during connecting to any Redis server. Default is 10000 milliseconds.
Importance: Medium
Type: Long
Default Value: 10000
Validator: [100,...]
Flag to determine if SSL is enabled.
Importance: Medium
Type: Boolean
Default Value: false
The SSL provider to use.
Importance: Low
Type: String
Default Value: JDK
Validator: Matches: OPENSSL, JDK
The password for the SSL keystore.
Importance: Medium
Type: Password
Default Value: [hidden]
The path to the SSL keystore.
Importance: Medium
Type: String
The password for the SSL truststore.
Importance: Medium
Type: Password
Default Value: [hidden]
The path to the SSL truststore.
Importance: Medium
Type: String
Master server name used by Redis Sentinel servers and master change monitoring task.
Importance: Medium
Type: String
Default Value:
Error will be thrown if Redis command can't be sent to Redis server after retryAttempts.
But if it sent successfully then timeout will be started.
Importance: Medium
Type: Integer
Default Value: 3
Defines time interval for another one attempt send Redis command
if it hasn't been sent already.
Default is 1500 milliseconds
Importance: Medium
Type: Integer
Default Value: 1500