I’m working with kafka consumers using golang. Previously there is a consumer codebase which is running on server with consumer group consumer-1 and in that consumer there is so many data that it is reading working fine. But now I’m making and another consumer with the same group id with below configuration but it’s not receiving the messages.

Code base

  reader := kafka.NewReader(kafka.ReaderConfig{
            Brokers:          []string{config.KAFKA.Broker},
            Topic:            newTopic,
            MaxBytes:         10485760,
            GroupID:          "consumer-1",
            MaxWait:          time.Duration(2 * time.Second),
            ReadBatchTimeout: time.Duration(2 * time.Second),
            QueueCapacity:    10000,
            // Dialer:           dailer,
        })

Library I’m using

"github.com/segmentio/kafka-go"

This is above configuration that I did in previous code this is same. Please let me know why this is not working. Any suggestions, help will be appreciated.