Kafka生产者如何查找记录的模式ID？

Kafka生产者在将记录发送到Kafka之前需要将记录的模式ID与其关联。下面是一个示例解决方法，使用Avro格式来发送记录：

1.首先，我们需要为记录定义一个Avro模式，如下所示：

{
  "type": "record",
  "name": "User",
  "fields": [
    {"name": "name", "type": "string"},
    {"name": "age", "type": "int"},
    {"name": "email", "type": "string"},
    {"name": "address", "type": "string"}
  ]
}

2.接下来，我们需要使用Avro的Schema Registry服务来注册这个模式，并获取相应的模式ID，如下所示：

Schema.Parser parser = new Schema.Parser();

Schema schema = parser.parse(schemaJson);
int schemaId = schemaRegistry.registerSchema("user-schema", schema);

3.现在，我们可以将记录与其关联的模式ID一起发送到Kafka，如下所示：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
props.put("schema.registry.url", "http://localhost:8081");
props.put("auto.register.schemas", "false");

Producer<String, GenericRecord> producer = new KafkaProducer<>(props);

String topic = "user-topic";
String key = "key-1";
GenericRecord record = new GenericData.Record(schema);

record.put("name", "John Doe");
record.put("age", 30);
record.put("email", "johndoe@example.com");
record.put("address", "123 Main St");

producer.send(new ProducerRecord<String, GenericRecord>(topic, key, record)).get();

在上面的示