add no-consumers flag to be set on shared clusters

config/config.go

@@ -38,13 +38,14 @@ var (
 	Port              string
 	Retention         int64
 	AuthType          string
-	Version           string = "0.3.7"
+	Version           string = "0.3.8"
 	GitCommit         string = "HEAD"
 	JMXRequestTimeout time.Duration
 	KafkaDir          string
 	ZookeeperURL      []string
 	WebRequestTimeout time.Duration = 5 * time.Second
 	DevMode           bool          = false
+	NoConsumers       bool          = false
 )
 
 func PrintConfig() {

config/flags.go

@@ -14,6 +14,7 @@ var (
 	zk             = flag.String("zookeeper", "localhost:2181", "The connection string for the zookeeper connection in the form host:port. Multiple hosts can be given to allow fail-over.")
 	kafkaDir       = flag.String("kafkadir", "/opt/kafka", "The directory where kafka lives")
 	devMode        = flag.Bool("dev", false, "Devmode add more logging and reloadable assets")
+	noConsumers    = flag.Bool("no-consumers", false, "Disable listing of consumer groups")
 )
 
 func Parse() {
@@ -25,5 +26,6 @@ func Parse() {
 	KafkaDir = *kafkaDir
 	ZookeeperURL = strings.Split(*zk, ",")
 	DevMode = *devMode
+	NoConsumers = *noConsumers
 	PrintConfig()
 }

server/api/consumers.go

@@ -4,6 +4,7 @@ import (
 	"net/http"
 	"sort"
 
+	"github.com/cloudkarafka/cloudkarafka-manager/config"
 	mw "github.com/cloudkarafka/cloudkarafka-manager/server/middleware"
 	"github.com/cloudkarafka/cloudkarafka-manager/store"
 	"goji.io/pat"
@@ -15,6 +16,10 @@ func ListConsumerGroups(w http.ResponseWriter, r *http.Request) {
 		http.Error(w, "Unauthorized", http.StatusUnauthorized)
 		return
 	}
+	if config.NoConsumers {
+		writeAsJson(w, Page(1, 1, store.ConsumerSlice{}))
+		return
+	}
 	ps, p, err := pageInfo(r)
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusBadRequest)