KafkaAvroDeserializer使用的默认SchemaRegistryClient的查询

要查询KafkaAvroDeserializer使用的默认SchemaRegistryClient，你可以使用以下代码示例：

import io.confluent.kafka.serializers.KafkaAvroDeserializer;
import io.confluent.kafka.serializers.subject.TopicNameStrategy;
import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient;
import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient;

public class KafkaAvroDeserializerExample {
    public static void main(String[] args) {
        String schemaRegistryUrl = "http://localhost:8081";
        String topicName = "my-topic";

        // 创建SchemaRegistryClient对象
        SchemaRegistryClient schemaRegistryClient = new CachedSchemaRegistryClient(schemaRegistryUrl, 100);

        // 创建KafkaAvroDeserializer对象
        KafkaAvroDeserializer avroDeserializer = new KafkaAvroDeserializer(schemaRegistryClient);
        avroDeserializer.configure(getDeserializerConfig(), false);

        // 获取KafkaAvroDeserializer使用的默认SchemaRegistryClient的查询
        String defaultSchemaRegistryQuery = avroDeserializer.registryClient
                .getSchemaMetadata(topicName + "-value", avroDeserializer.registryClient.latestVersion());

        System.out.println("Default Schema Registry Query: " + defaultSchemaRegistryQuery);
    }

    private static Map<String, Object> getDeserializerConfig() {
        Map<String, Object> config = new HashMap<>();
        // 设置其他KafkaAvroDeserializer的配置（如果需要）
        return config;
    }
}

请注意，上述代码假设你已经使用Confluent Schema Registry搭建了一个本地的Schema Registry服务，并且该服务运行在http://localhost:8081上。你还需要替换topicName变量为你要查询的主题名称。