我正在尝试从kafka主题获取消息，并查看如果我将auto.commit.reset策略设置为“earlish”，所有消息都会得到正确处理。但如果设置为“latest”，则第一条消息将丢失，其余消息将得到正确处理。如果我漏了什么，有人能帮忙吗？
7gyucuyw1#
假设您正在使用的组没有提交任何偏移量，则在设置 auto.commit.reset 至 latest 消费者只会收到新的信息，所以我不太清楚你说的“第一条信息”是什么意思。
auto.commit.reset
latest
1条答案
按热度按时间7gyucuyw1#
假设您正在使用的组没有提交任何偏移量，则在设置
auto.commit.reset至latest消费者只会收到新的信息，所以我不太清楚你说的“第一条信息”是什么意思。