search

AbsaOSS / ABRiS

Avro SerDe for Apache Spark structured APIs.
Apache License 2.0
227 stars 73 forks source link

TopicNameStrategy issue #338

Closed talperetz1 closed 1 year ago

talperetz1 commented 1 year ago

Hi, I am using andTopicNameStrategy this is my code

        AbrisConfig.fromConfluentAvro.downloadReaderSchemaByLatestVersion
          .andTopicRecordNameStrategy(topic, schemaName, "")
          .usingSchemaRegistry(
            schemaRegistryUrl.getOrElse(
              throw new RuntimeException(
                "no schema registry url provided"
              )
            )
          )

and when I am trying to ran my spark job I get this error org.apache.avro.SchemaParseException: Illegal initial character: 1-value

Any idea why its happening?

cerveada commented 1 year ago

Can you inspect the schema if it's valid?