DTStack / DTStack/chunjun

kakfareader配置groupId无效的问题

Open
#613 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

kafkareader在配置groupId后,使用本地模式启动任务,可以看到消费kafka数据,但是没有提交offset,kafkatool查看一直有lag
![image](https://user-images.githubusercontent.com/16069974/155723151-758cc0e7-6e6f-4df1-9b18-741fae014db5.png)
导致每次重新启动的时候,都重复消费,求大佬们赐教!!

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.