From 5c0a6be99b467e7da48ef2f422c233f657c0f9bb Mon Sep 17 00:00:00 2001 From: David Neves Date: Tue, 27 Aug 2019 16:08:41 +0100 Subject: [PATCH] Update main.go --- main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.go b/main.go index b761095..f755570 100755 --- 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") )