[GitHub] [beam] damccorm opened a new issue, #21190: KafkaIO Connector-updating/overwriting consumer groupid with random prefix

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

damccorm opened a new issue, #21190:
URL: https://github.com/apache/beam/issues/21190

   Apache beam version: 2.27
   
   Connector: KafkaIO
   
   cloud service : GCP Dataflow
   
   language : JAVA11
   
   we are trying to read the avro messages from confluent kafka topic using dataflow service as a consumer. (Using KafkaIO Connector)
   
   While trying to access the schema registry using provided (schema url, subject, version, ssl configuration(keystore,truststore..etc))  details , we are getting the below error.
   
    
   {color:#ef6950}Error message from worker: org.apache.kafka.common.errors.GroupAuthorizationException:{color}
    {color:#ef6950}Not authorized to access group: initialOffset_offset_consumer_1179967555_kafka-connectivity-test{color}
    
   Expected Result : Consumer groupid should not change also should able to connect kafka consumer.
    
   Actual Result: 
   Though the provided groupid was : kafka-connectivity-test, some how it is changing the value to  initialOffset_offset_consumer_1179967555_kafka-connectivity-test.
    
   PFA related code snippets. 
    
   !image-2021-09-14-17-34-21-672.png!
    
   
   Imported from Jira [BEAM-12880](https://issues.apache.org/jira/browse/BEAM-12880). Original Jira may contain additional context.
   Reported by: Logesh.


-- 
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: github-unsubscribe@beam.apache.org.apache.org

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