【问题标题】:confluent ksqlDB can not create stream汇合的ksqlDB无法创建流
【发布时间】:2021-07-03 22:26:53
【问题描述】:

我想为用户主题创建流

但是,ksqlDB 无法创建流。

Specify KSQL Stream Subject names explicitly

【问题讨论】:

  • 您是如何填充users 主题的?架构注册表中是否存在架构?
  • 顺便说一句,如果您将 CLI 中的文本直接放入您的问题中,而不是图像中,人们会更容易提供帮助 :)
  • 架构注册表中是否存在架构?这是什么?
  • 如果您指定 VALUE_FORMAT='AVRO',则需要使用 Avro 序列化程序对数据进行序列化,该序列化程序将架构放置在架构注册表中。
  • 我使用 mysql 数据库和 debezuim 将 kafka 连接到 mysql。可以在任何地方使用 JSON 格式而不是 AVRO 吗?怎么样?

标签: apache-kafka confluent-platform ksqldb


【解决方案1】:

您应该首先在模式注册表中创建一个主题名称为“user-value”的模式,然后您可以创建流。 如何将架构发布到架构注册表,请访问https://docs.confluent.io/platform/current/schema-registry/develop/using.html

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多