apache/pinot

Handle change in default groupId behavior in kafka consumer

Open

#9,183 建立於 2022年8月9日

在 GitHub 查看
 (4 留言) (0 反應) (0 負責人)Java (1,234 fork)batch import
good first issue

倉庫指標

Star
 (4,937 star)
PR 合併指標
 (平均合併 6天 7小時) (30 天內合併 186 個 PR)

描述

Starting kafka 2.2.0 onwards, when group.id is not specified in the kafka consumer config, it is set as null, instead of an empty string. Due to this change, even though auto-commit is enabled, it doesn't show up in the consumer offsets topics. This breaks existing kafka monitoring tools.

One proposed solution is for Pinot to set a default group id when it was not explicitly configured by user (say, table name as the default group id).

貢獻者指南