There’s no need to build Flink. Implement your own
org.apache.flink.formats.avro.SchemaCoder, and the
SchemaCoder.SchemaCoderProvider accepted by the constructor of
org.apache.flink.formats.avro.RegistryAvroSerializationSchema.
This way, you can replace the dangerous “register()” with simply “g
This comes up when the Schema Registry has authorization capabilities.
A producing application may not be authorized to call “register” when another
principal owns the schema subject, for example in organizations with strong
schema governance practices. When ConfluentSchemaRegistryCoder.writeSch
