首页 > 解决方案 > Quarkus 原生,带有 Kafka Streams 和 Schema Registry

问题描述

Quarkus (1.5.0.Final) 作为本机可执行文件可以很好地与 Kafka Streams 和 Avro Schema Registry 配合使用。但是如果 Kafka 流使用 Avro Serdes 使用主题,如果添加了新事件,则会出现异常:

kafka-streams-avro-serde 库尝试访问(通过 REST API)添加了模式的模式注册表。发生以下异常:(这在 Qaurkus + JVM 中运行良好)

原因:org.apache.kafka.common.errors.SerializationException:注册 Avro 架构时出错:{“type”:“record”,“name”:“siteconf”,“namespace”:“test”,“fields”:[ {"name":"id","type":["null","string"],"default":null},{"name":"site","type":["null","string "],"default":null},{"name":"configuration","type":["null","string"],"default":null}],"connect.name":"siteconf"引起:io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:内部服务器错误;错误代码:500

我不知道如何解决这个问题。这很烦人,因为我认为这是我在带有 Schema Registry 的 Kafka Streams 中检测到的唯一一个问题。我对采用 Quarkus 而不是 Spring Boot/Cloud 很感兴趣

标签: apache-kafka-streamsquarkusconfluent-schema-registrygraalvm

解决方案


推荐阅读