VOL-3943 - multiple stack configuration support
Change-Id: I28cb26b6cd6fbc5b3f0e8d406a68bf5c964a57fd
diff --git a/internal/pkg/commands/message.go b/internal/pkg/commands/message.go
index bef4cac..338affd 100644
--- a/internal/pkg/commands/message.go
+++ b/internal/pkg/commands/message.go
@@ -353,7 +353,7 @@
func (options *MessageListenOpts) Execute(args []string) error {
ProcessGlobalOptions()
- if GlobalConfig.Kafka == "" {
+ if GlobalConfig.Current().Kafka == "" {
return errors.New("Kafka address is not specified")
}
@@ -361,7 +361,7 @@
config.ClientID = "go-kafka-consumer"
config.Consumer.Return.Errors = true
config.Version = sarama.V1_0_0_0
- brokers := []string{GlobalConfig.Kafka}
+ brokers := []string{GlobalConfig.Current().Kafka}
client, err := sarama.NewClient(brokers, config)
if err != nil {