我使用下面的代码（不是真的，但假设是这样）创建一个模式，并由生产者将其发送给kafka。

public static final String USER_SCHEMA = "{"
        + "\"type\":\"record\","
        + "\"name\":\"myrecord\","
        + "\"fields\":["
        + "  { \"name\":\"str1\", \"type\":\"string\" },"
        + "  { \"name\":\"str2\", \"type\":\"string\" },"
        + "  { \"name\":\"int1\", \"type\":\"int\" }"
        + "]}";

public static void main(String[] args) throws InterruptedException {
    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");

    Schema.Parser parser = new Schema.Parser();
    Schema schema = parser.parse(USER_SCHEMA);
    Injection<GenericRecord, byte[]> recordInjection = GenericAvroCodecs.toBinary(schema);

    KafkaProducer<String, byte[]> producer = new KafkaProducer<>(props);

    for (int i = 0; i < 1000; i++) {
        GenericData.Record avroRecord = new GenericData.Record(schema);
        avroRecord.put("str1", "Str 1-" + i);
        avroRecord.put("str2", "Str 2-" + i);
        avroRecord.put("int1", i);

        byte[] bytes = recordInjection.apply(avroRecord);

        ProducerRecord<String, byte[]> record = new ProducerRecord<>("mytopic", bytes);
        producer.send(record);

        Thread.sleep(250);

    }

    producer.close();
}

问题是代码只允许我用这个模式发送一条消息。然后我需要更改架构名称以便发送下一条消息。。。所以名称字符串现在是随机生成的，所以我可以发送更多的消息。这是一个黑客，所以我想知道正确的方法来做这件事。
我还研究了如何在没有模式的情况下发送消息（即已经向kafka发送了一条带有模式的消息，现在所有其他消息都不再需要模式了） new GenericData.Record(..) 需要架构参数。如果为空，则会抛出一个错误。
那么，向Kafka发送avro模式消息的正确方法是什么呢？
下面是另一个代码示例-与我的非常相同：
https://github.com/confluentinc/examples/blob/kafka-0.10.0.1-cp-3.0.1/kafka-clients/producer/src/main/java/io/confluent/examples/producer/producerexample.java
它也没有显示如何在不设置模式的情况下发送。