[GitHub] [pinot] Jackie-Jiang commented on pull request #9260: added a default groupid in kafka consumer

[GitBox <gi...@apache.org>]

Jackie-Jiang commented on PR #9260:
URL: https://github.com/apache/pinot/pull/9260#issuecomment-1247382302

   > I agree that the empty string will match the existing behavior. But it doesn't provide any value to the application. if you have more than one kafka table, they will all share the same group id, which in my opinion, is a bug or incorrect implementation. I think we can use the table name as the group id and prefix it with `stream-level` or `partition-level` based on the consumption model used. For existing applications that may rely on an empty string group id, they can always add a table config to override the `group.id` kafka consumer property. Wdyt @Jackie-Jiang ?
   
   Does `groupId` apply to LLC consumer? I checked the usage of `StreamConfig.getGroupId()` and I think we already handled the case of missing group id (in `PinotTableIdealStateBuilder.getGroupIdFromRealtimeDataTable()`). @navina In which scenario are we getting the `null` group id?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org