Update the utils funcations

utils/config.go

@@ -14,6 +14,7 @@ type Confg struct {
 	Password   string
 	Groupid    string
 	Topic      string
+	MsgSize    string
 }
 
 func LoadConfig() *Confg {
@@ -26,6 +27,7 @@ func LoadConfig() *Confg {
 	c.Password = getConfig("KAFKA_PASSWORD", "password", "", "Kafka broker password")
 	c.Groupid = getConfig("KAFKA_GROUPID", "gid", "gid", "Kafka group id")
 	c.Topic = getConfig("KAFKA_TOPIC", "topic", "topic", "Kafka topic name")
+	c.MsgSize = getConfig("KAFKA_MSGSIZE", "msgsize", "10", "Kafka message size")
 
 	return &c
 }

utils/logdebug.go

@@ -0,0 +1,10 @@
+package utils
+
+import "log"
+
+// DebugLogging helper func to log debug
+func DebugLogging(logstring string, enableDebug bool) {
+	if enableDebug {
+		log.Printf(logstring)
+	}
+}

utils/randstring.go

@@ -0,0 +1,16 @@
+package utils
+
+import (
+	"math/rand"
+)
+
+var letters = []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ")
+
+// RandString genrates rand messages to produce
+func RandString(n int) string {
+	b := make([]rune, n)
+	for i := range b {
+		b[i] = letters[rand.Intn(len(letters))]
+	}
+	return string(b)
+}