diff --git a/config/settings.go b/config/settings.go
index 6b5b183..9183651 100644
--- a/config/settings.go
+++ b/config/settings.go
@@ -3,6 +3,7 @@ package config
 import (
 	log "github.com/sirupsen/logrus"
 	"os"
+	"strconv"
 )
 
 var SettingsObj *Settings
@@ -14,6 +15,7 @@ type Settings struct {
 	RedisPort         string
 	SlackReportingUrl string
 	DataMarketAddress string
+	RedisDb           int
 }
 
 func LoadConfig() {
@@ -37,14 +39,28 @@ func LoadConfig() {
 	if config.DataMarketAddress == "" {
 		missingEnvVars = append(missingEnvVars, "DATA_MARKET_ADDRESS")
 	}
+	if getEnv("REDIS_DB", "") == "" {
+		missingEnvVars = append(missingEnvVars, "REDIS_DB")
+	}
+	if config.RedisHost == "" {
+		missingEnvVars = append(missingEnvVars, "REDIS_HOST")
+	}
+	if config.RedisPort == "" {
+		missingEnvVars = append(missingEnvVars, "REDIS_PORT")
+	}
 
 	if len(missingEnvVars) > 0 {
 		log.Fatalf("Missing required environment variables: %v", missingEnvVars)
 	}
 
+	redisDb, err := strconv.Atoi(getEnv("REDIS_DB", ""))
+	if err != nil || redisDb < 0 {
+		log.Fatalf("Invalid REDIS_DB value: %s", config.RedisDb)
+	}
+
+	config.RedisDb = redisDb
+
 	checkOptionalEnvVar(config.SlackReportingUrl, "SLACK_REPORTING_URL")
-	checkOptionalEnvVar(config.RedisHost, "REDIS_HOST")
-	checkOptionalEnvVar(config.RedisPort, "REDIS_PORT")
 
 	SettingsObj = &config
 }
diff --git a/pkgs/redis/client.go b/pkgs/redis/client.go
index 31bba69..ffd665b 100644
--- a/pkgs/redis/client.go
+++ b/pkgs/redis/client.go
@@ -18,7 +18,7 @@ func NewRedisClient() *redis.Client {
 	return redis.NewClient(&redis.Options{
 		Addr:         fmt.Sprintf("%s:%s", config.SettingsObj.RedisHost, config.SettingsObj.RedisPort), // Redis server address
 		Password:     "",                                                                               // no password set
-		DB:           0,
+		DB:           config.SettingsObj.RedisDb,
 		PoolSize:     1000,
 		ReadTimeout:  200 * time.Millisecond,
 		WriteTimeout: 200 * time.Millisecond,