[GitHub] [spark] Tagar commented on pull request #29729: [SPARK-32032][SS] Avoid infinite wait in driver because of KafkaConsumer.poll(long) API

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

Tagar commented on pull request #29729:
URL: https://github.com/apache/spark/pull/29729#issuecomment-697969651


   Just wondering if this authorization any different in Confluent Kafka (vs OSS Kafka)? 
   I was trying to follow this 
   https://docs.confluent.io/current/kafka/authorization.html 
   ``` 
   **Group**
   Groups in the brokers. 
   All protocol calls that work with groups, such as joining a group, 
   must have corresponding privileges with the group in the subject. 
   
   Group (**group.id**) can mean Consumer Group, Stream Group (application.id), 
   Connect Worker Group, or any other group that uses the 
   Consumer Group protocol, like Schema Registry cluster.
   ```
   
   


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

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



---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org