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

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

pjpringle commented on PR #9260:
URL: https://github.com/apache/pinot/pull/9260#issuecomment-1279874075

   I think this change will break the current topic partition assignment and replication behaviour by defaulting back to the Kafka clients implementation instead of Pinot's implementation.
   
   Kafka client will assign partitions across consumer instances and stops a partition from being consumed by 2 or more processes if the group id is the same.
   
   Please test a multi partition topic with replication enabled.
   
   If the issue here is monitoring lags I believe there is a rest endpoint in swagger to give the consumer offsets as well as the last consuming time stamp in the query results.
   
   


-- 
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