diff --git a/cmd/kgo-repeater/main.go b/cmd/kgo-repeater/main.go index 5f55b8c..071f795 100644 --- a/cmd/kgo-repeater/main.go +++ b/cmd/kgo-repeater/main.go @@ -115,6 +115,10 @@ func main() { topicsList = strings.Split(*topic, ",") } + if *group == "" { + panic("A consumer group must be provided via the -group flag") + } + dataInFlightPerWorker := (*initialDataMb * 1024 * 1024) / uint64(*workers) if dataInFlightPerWorker / *payloadSize <= 0 {