apache/pinot

Handle change in default groupId behavior in kafka consumer

开放

#9,183 创建于 2022年8月9日

 (4 条评论) (0 个反应) (0 位负责人)Java (1,234 个派生)batch import
good first issue

仓库指标

星标
 (4,937 个星标)
PR 合并指标
 (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).

贡献者指南