KafkaIO Connector-updating/overwriting consumer groupid with random prefix

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.