DTStack / DTStack/chunjun

kakfareader配置groupId无效的问题

Aperta
#613 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
Java
Stelle
4.1k
Fork
1.7k
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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

Guida per i contributori

Apri la guida per i contributori

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.