模式注册表KAFKA:如何将其集成到java项目中？

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-schema-registry-client</artifactId>
    <version>5.5.0</version>
</dependency>

kafka.schema.registry.url=http://localhost:8081

Schema userSchema = SchemaBuilder.record("User")
    .fields()
    .requiredString("name")
    .requiredInt("age")
    .endRecord();

SchemaRegistryClient schemaRegistryClient = new CachedSchemaRegistryClient(kafka.schema.registry.url, 100);
int schemaId = schemaRegistryClient.register("User", userSchema);

GenericRecord userRecord = new GenericData.Record(userSchema);
userRecord.put("name", "John");
userRecord.put("age", 25);

byte[] serializedData = AvroSerializer.serialize(userRecord, schemaId);

GenericRecord deserializedData = AvroDeserializer.deserialize(serializedData, schemaId);
String name = (String) deserializedData.get("name");
int age = (int) deserializedData.get("age");