Golang Kafka Reader не может читать сообщения из темы - PullRequest
Новая
       21

Golang Kafka Reader не может читать сообщения из темы

0 голосов
/ 10 февраля 2020

У меня есть группа потребителей Kafka (Golang / Segmentio) с одним ридером. Читатель не может прочитать сообщения из topi c, но я могу создать писателя в том же фрагменте кода и записать в топи c, из которого читатель не может читать.

Ниже приведен мой код для создания считывателя kafka: 

    reader := kafka.NewReader(kafka.ReaderConfig{
        Brokers:     []string{"host.docker.internal:9092"},
        GroupID:     kafkaGroupID,
        Topic:       "test-topic",
        MinBytes:    10e3,
        MaxBytes:    10e6,
        StartOffset: kafka.FirstOffset,
    })

Я попытался настроить считыватель с «StartOffset» для FirstOffset и LastOffset, но безуспешно.

Я запускаю это локально на MacOS , Из журналов контейнера kafka docker я смог убедиться, что topi c был успешно создан. Однако я могу видеть сообщения в topi c, используя kafkacat, используя другой идентификатор группы.

У меня нет идей, как решить эту проблему. Буду очень признателен за любые идеи или советы о том, чего мне не хватает или способы отладки.

...