apache-kafka-streams - 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 很感兴趣
解决方案
推荐阅读
- docker - 如何从 Jenkins 构建作业在 Linux 部署服务器上部署 docker-compose 文件?
- css - 在页面上延迟应用 css
- c# - 用列表框中的一些文本分隔字符串
- php - Docker php-fpm 作为 www-data 运行
- wix - Wix 安装后和卸载前可执行文件
- javascript - 去抖内部的开关盒内部的正则表达式不起作用
- sql - 时间戳间隔上的 Postgres 语法错误
- apache-spark - 组合(不是 sql 连接)2 个 spark 数据帧
- openssl - EVP_EncryptUpdate 缺少 4 个字节
- kotlin - Freemarker 为“TheApp”对象提供未解决的参考