Error 401 using KafkaIO to access to schema registry

Schema Registry
1

Hello, i’m trying to connect to the schema registry using KafkaIO, but i receive this error:

io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Unauthorized; error code: 401

props.put("schema.registry.url", "https://schema_registry_url");
props.put("basic.auth.credentials.source", "USER_INFO");
props.put("basic.auth.user.info", "KEY:PASSWORD");

   PCollection<KV<String, String>> entries =
                pipeline
                        .apply(
                                "Read Entries from Confluent Cloud Topic",
                                KafkaIO.<String, String>read()
                                        .withBootstrapServers(bootstrapserver)
                                        .withTopic(TOPIC)
                                        .withConsumerConfigUpdates(props)
                                        .withKeyDeserializer(StringDeserializer.class)
                                        .withValueDeserializer(ConfluentSchemaRegistryDeserializerProvider.of(SCHEMA_URL, TOPIC))
                                        .withoutMetadata()
                        );
2

Welcome to the forum!

Assuming that you are using “https://schema_registry_url”. and “KEY:PASSWORD” as placeholders for the real values, have you verified that the values you are using for key and password are the correct ones for the schema registry URL that you are trying to access?

1 Like