小编Ali*_*let的帖子

在 Spring Boot 应用程序中使用 Confluence 中的架构注册表与 Avro 和 Kafka

首先,我必须说我对 confluence 并不熟悉。

我正在关注本教程:https://www.confluence.io/blog/schema-registry-avro-in-spring-boot-application-tutorial/,但我陷入了困境。

我无法为 Kafka 创建使用者,因为我收到错误:io.confluence.common.config.ConfigException:缺少没有默认值的所需配置“schema.registry.url”。

我在 yml 配置中找不到此架构属性。

Confluence 在本地运行:

$: confluent local start
zookeeper is already running. Try restarting if needed
kafka is already running. Try restarting if needed
schema-registry is already running. Try restarting if needed
Starting kafka-rest
kafka-rest is [UP]
Starting connect
connect is [UP]
Starting ksql-server
ksql-server is [UP]
Starting control-center
control-center is [UP]
Run Code Online (Sandbox Code Playgroud)

在 Spring 中设置用户主题后,从控制中心我看到了不同的模式:

{
  "connect.name": "ksql.users",
  "fields": [
    {
      "name": "registertime",
      "type": "long"
    },
    {
      "name": "userid",
      "type": …
Run Code Online (Sandbox Code Playgroud)

java apache-kafka spring-kafka confluent-schema-registry

7
推荐指数
1
解决办法
1万
查看次数