Update main.go

nosinovacao · Aug 27, 2019 · 5c0a6be · 5c0a6be
1 parent 88923fe
commit 5c0a6be
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/main.go b/main.go
@@ -156,8 +156,8 @@ func main() {
 		lokiAddr       = flag.String("lokiurl", "http://loki:3100", "the loki url, default is http://loki:3100")
 		buffer         = flag.Duration("buffer", 5*time.Second, "how much time to buffer before sending to loki")
 		brokerList     = flag.String("brokerList", "kafka.rancher2.zondev.lab:32400", "the kafka broker list")
-		clientID       = flag.String("clientid", "logtail-loki", "the kafka client id")
-		groupID        = flag.String("groupid", "logtail-loki", "the kafka group id")
+		clientID       = flag.String("clientid", "floki", "the kafka client id")
+		groupID        = flag.String("groupid", "floki", "the kafka group id")
 		sessionTimeout = flag.String("sessionTimeout", "6000", "kafka session timeout")
 		topicPattern   = flag.String("topicPattern", "^logging-*", "Regex pattern for kafka topic subscription")
 	)