tanmesh commented on PR #9260: URL: https://github.com/apache/pinot/pull/9260#issuecomment-1251716402
> As of today, we don't set any groupId explicitly in KafkaPartitionLevelStreamConfig.java. So, the default in the partition level consumer ends-up being empty string and with newer kafka version, it is null. You can set group.id explicitly in KafkaPartitionLevelStreamConfig.java. Also, I am unable to understand the above comment. Is `group.id` will be set similar to what is done [here](https://github.com/apache/pinot/pull/9260/files#diff-8a2ae243067a42eca9160d77eafb886e42a9aefe37046259d31d6fe7a31ada6dR101) . If yes, can you please point me to the document for better understand of how pinot kafka works. -- 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-unsubscr...@pinot.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org
