DTStack / DTStack/chunjun

kakfareader配置groupId无效的问题

Offen
#613 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Vorherrschende Sprache
Java
Sterne
4.1k
Forks
1.7k
PR-Merge-Kennzahlen
Keine gemergten PRs in 30 T.

Beschreibung

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

Beitragsleitfaden

Beitragsleitfaden öffnen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.