diff --git a/engine/core.go b/engine/core.go
index 96942c6aa..ccfa1203c 100644
--- a/engine/core.go
+++ b/engine/core.go
@@ -58,28 +58,6 @@ func (cS *CoreService) Status(arg *utils.TenantWithArgDispatcher, reply *map[str
 	response[utils.Version] = utils.GetCGRVersion()
 	response[utils.RunningSince] = utils.GetStartTime()
 	response[utils.GoVersion] = runtime.Version()
-	// in case we need this info in the future
-	// response["Extra MemInfo"] = map[string]interface{}{
-	// 	"Alloc":       utils.SizeFmt((float64)(memstats.Alloc), ""),
-	// 	"TotalAlloc":  utils.SizeFmt((float64)(memstats.TotalAlloc), ""),
-	// 	"Sys":         utils.SizeFmt((float64)(memstats.Sys), ""),
-	// 	"Mallocs":     utils.SizeFmt((float64)(memstats.Mallocs), ""),
-	// 	"Frees":       utils.SizeFmt((float64)(memstats.Frees), ""),
-	// 	"HeapAlloc":   utils.SizeFmt((float64)(memstats.HeapAlloc), ""),
-	// 	"HeapSys":     utils.SizeFmt((float64)(memstats.HeapSys), ""),
-	// 	"HeapIdle":    utils.SizeFmt((float64)(memstats.HeapIdle), ""),
-	// 	"HeapInuse":   utils.SizeFmt((float64)(memstats.HeapInuse), ""),
-	// 	"StackInuse":  utils.SizeFmt((float64)(memstats.StackInuse), ""),
-	// 	"StackSys":    utils.SizeFmt((float64)(memstats.StackSys), ""),
-	// 	"MSpanInuse":  utils.SizeFmt((float64)(memstats.MSpanInuse), ""),
-	// 	"MSpanSys":    utils.SizeFmt((float64)(memstats.MSpanSys), ""),
-	// 	"MCacheInuse": utils.SizeFmt((float64)(memstats.MCacheInuse), ""),
-	// 	"MCacheSys":   utils.SizeFmt((float64)(memstats.MCacheSys), ""),
-	// 	"BuckHashSys": utils.SizeFmt((float64)(memstats.BuckHashSys), ""),
-	// 	"GCSys":       utils.SizeFmt((float64)(memstats.GCSys), ""),
-	// 	"OtherSys":    utils.SizeFmt((float64)(memstats.OtherSys), ""),
-	// 	"NextGC":      utils.SizeFmt((float64)(memstats.NextGC), ""),
-	// }
 	*reply = response
 	return
 }
diff --git a/ers/kafka.go b/ers/kafka.go
index 88cd02efa..8f4571aa0 100644
--- a/ers/kafka.go
+++ b/ers/kafka.go
@@ -37,7 +37,7 @@ import (
 
 const (
 	defaultTopic   = "cgrates_cdrc"
-	defaultGroupID = "cgrates_conumer"
+	defaultGroupID = "cgrates_consumer"
 
 	// ToDo: export it to utils
 	topic   = "topic"
diff --git a/ers/reader.go b/ers/reader.go
index 82c593206..075aca6d4 100644
--- a/ers/reader.go
+++ b/ers/reader.go
@@ -40,6 +40,8 @@ func NewEventReader(cfg *config.CGRConfig, cfgIdx int,
 		err = fmt.Errorf("unsupported reader type: <%s>", cfg.ERsCfg().Readers[cfgIdx].Type)
 	case utils.MetaFileCSV:
 		return NewCSVFileER(cfg, cfgIdx, rdrEvents, rdrErr, fltrS, rdrExit)
+	case utils.MetaKafkajsonMap:
+		return NewKafkaER(cfg, cfgIdx, rdrEvents, fltrS, rdrExit, appExit)
 	}
 	return
 }