- 2489 Views
- 3 replies
- 0 kudos
I am trying to write a data frame to Kafka topic with Avro schema for key and value using a schema registry URL. The to_avro function is not writing t...
I am trying to write a data frame to Kafka topic with Avro schema for key and value using a schema registry URL. The to_avro function is not writing to the topic and throwing an exception with code 40403 something. Is there an alternate way to do thi...
- 2489 Views
- 3 replies
- 0 kudos
- 0 kudos
Hi,Could you please refer to https://github.com/confluentinc/kafka-connect-elasticsearch/issues/59 and let us know if this helps.
- 0 kudos
- 2363 Views
- 2 replies
- 1 kudos
Resolved! Accessing confluent schema registry from databricks with scala fails with 401 (just for scala, not python, just in databricks)
Nore, I've tested with the same connection variable:locally with scala - works (via the same prod schema registry)in the cluster with python - worksin the cluster with scala - fails with 401 auth errordef setupSchemaRegistry(schemaRegistryUrl: String...
- 2363 Views
- 2 replies
- 1 kudos
- 1 kudos
Found the issue: it's the uber package mangling some dependency resolving, which I fixedAnother issue, is that currently you can't use 6.* branch of confluent schema registry client in databricks, because the avro version is different then the one su...
- 1 kudos