检索Avro架构时出错找不到架构错误代码40403

Question

我有Kafka的以下配置

我试图通过版本得到主题，我得到如下

curl -u reader:reader -s "https://schema-registry1:8081/subjects/add_bank_account/versions/1/" | jq
{
  "subject": "add_bank_account",
  "version": 1,
  "id": 46,
  "schema": "{\"type\":\"record\",\"name\":\"CreateBankAccount\",\"namespace\":\"com.test.serviceprovider.avro\",\"fields\":[{\"name\":\"exerciceFrameworkId\",\"type\":\"string\"},{\"name\":\"agreementFileId\",\"type\":\"string\"},{\"name\":\"conventionCode\",\"type\":\"string\"}]}"
}

我使用插件<；代码>；avro-maven插件>；生成>；CreateBankAccount>；代码<

CreateBankAccount createBankAccount = CreateBankAccount.newBuilder()
    .setExerciceFrameworkId(event.exerciceFrameworkId)
    .setAgreementFileId(event.agreementFileId)
    .setConventionCode(convention.getConventionCode()).build();

然后，我用一个字符串键和一个avro序列化的有效负载向主题推送一条消息，但是我有一个错误

MessageChannel messageChannel = kafkaStreams.addBankAccount();
messageChannel.send(MessageBuilder.withPayload(createBankAccount)
   .setHeader(KafkaHeaders.MESSAGE_KEY, UUID.randomUUID().toString()).build());

轨道：

ProducerConfig值：

KafkaAvroSerializerConfig值：

Answer 1

您使用的是主题名称策略，因此注册表中的主题名称必须是

您还可以设置auto.register.schemas=true，而不是使用一些自定义名称自行注册架构。