注册schema时出错。通过KafkaREST无法生成AVRO消息。错误代码：40801。

这个错误可能是由于Kafka REST服务无法访问注册schema所需的资源而导致的。为了解决这个问题，可以尝试在Kafka REST配置文件中添加以下内容：

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

其中，http://localhost:8081应该是您正在运行注册schema的URL地址。通过添加这个配置，Kafka REST就可以访问您的注册schema服务以获取所需的资源，并成功生成AVRO消息。

另外，还可以检查所使用的schema是否正确，以及消息格式是否符合AVRO标准。以下是一个发送AVRO消息给Kafka的Java示例代码：

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", StringSerializer.class); props.put("value.serializer", KafkaAvroSerializer.class); props.put("schema.registry.url", "http://localhost:8081"); // 注册schema的URL

Schema schema = new Schema.Parser().parse(new File("user.avsc"));

KafkaProducer<String, GenericRecord> producer = new KafkaProducer<>(props); GenericData.Record user = new GenericData.Record(schema); user.put("id", 1); user.put("name", "张三"); user.put("age", 20);

ProducerRecord<String, GenericRecord> record = new ProducerRecord<>("my_topic", null, user); producer.send(record); producer.close();

通过上述代码，可以将一个AVRO格式的消息发送至名为my_topic的Kafka主题。需要注意的是，必须确保user.avsc文件包含所有必需的字段和类型。