0

我有一个 Kafka ConsumerGroup (Golang/Segmentio) 和一个读者。读者无法从某个主题读取消息，但我可以在同一段代码中创建一个编写器并写入读者无法读取的主题。

以下是我创建 kafka 阅读器的代码：

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

我尝试使用 FirstOffset 和 LastOffset 的“StartOffset”配置阅读器，但没有成功。

我在 MacOS 上本地运行它。从 kafka docker 容器日志中，我能够验证主题是否已成功创建。但是，我可以使用 kafkacat 使用不同的 groupID 查看主题中的消息。

我不知道如何解决这个问题。任何关于我可能遗漏的内容或调试方法的想法或提示将不胜感激。

4

0 回答 0