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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
