使用卡夫卡和动物园管理员，不同的组id不会从一开始就检索Kafka msgs。

Question

我们有卡夫卡v2.10和动物园管理员v3.4的设置和工作。我们已经写了高水平的消费者消费来自卡夫卡的日志信息。使用者A开始使用主题T和组id G1的消息(遵循Apache文档中提供的高级消费者示例)。然后，当消费者B以相同的主题T而组id G2开始时，它连接到kafka/动物园管理员，但是在消费者A使用的最后一个偏移量之后，它就会消耗日志消息。

我的理解是，它应该给出日志信息，从卡夫卡中为该主题提供的最低偏移量开始。知道它为什么不这么做吗？

我们还没有复制卡夫卡或动物园管理员。此时设置的OUr是简单而直接的，我们正试图让它们与基本功能一起工作。

任何帮助都是非常感谢的。

另外，您知道我们可以在哪里找到新目录，每次使用新组id的使用者建立与动物园管理员的连接(用于跟踪该组id的偏移量)时，假定动物园管理员都在创建这些目录吗？

Answer 1

您可以尝试在创建使用者组的同时将其添加到配置中吗？

    props.put("auto.offset.reset", "smallest");