apache-kafka - Kafka - 您可以在主题存在之前创建模式吗?它们之间的关系是什么?

标签 apache-kafka avro confluent-schema-registry

是否有任何必须遵守的命令 - 例如人们应该首先创建一个主题,然后在模式注册表中创建模式,反之亦然?

两个主题可以使用架构注册表中的相同架构吗?

每个主题都需要有Key和Value吗? (因此每个主题需要存在 2 个模式?)

关系和可能的组合是什么?

谢谢。

最佳答案

is there any order that must be followed

不。如果您启用了自动主题创建,您甚至可以立即开始为不存在的主题生成 Avro。 Confluence 序列化器自动注册模式,代理将创建一个具有默认分区和副本的主题

Can two topics use the same schema

是的,两个不同主题的 Avro Schema ID 可以相同。例如,在多个主题上共享的字符串的 Avro 键将导致两个主题被输入到注册表中,但是,只有一个架构 ID 会支持它们

Does every topic needs to have Key and Value?

是的。这是卡夫卡记录协议(protocol)的一部分。但是,该键可以为空。如果您没有对键或值使用 Avro 序列化程序,则不会进行任何输入。如果其中之一是,则您不需要对这两个选项都使用 Avro

关于apache-kafka - Kafka - 您可以在主题存在之前创建模式吗?它们之间的关系是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49982577/

相关文章:

apache-kafka - 有没有办法清除Kafka中的主题?

scala - 在 Spark Streaming 中反序列化来自 Kafka 的 Avro 格式数据给出空字符串和 0 for long

apache-spark - Hive中的import table命令如何获取架构?

hadoop - Hadoop Streaming 的向后兼容性

java - 如何像使用 avro console producer 一样生成 Kafka avro 记录?

apache-kafka - 将 Confluence Schema Registry 与 MSK 结合使用

java - Kafka 强制 JKS 重新加载

docker - 向主机 Kafka 服务器生成消息时出现容器化 Kafka 客户端错误

file - 与其他格式相比, Parquet 格式的优缺点是什么?

python - 类型错误 : Object of type 'mappingproxy' is not JSON serializable