模式注册表中的关键模式是什么?

chi*_*wan 4 java avro apache-kafka confluent-schema-registry

我对键模式没有确切的概念,它是什么,以及为什么它必须用作键是自动生成的,我们只是传递一个值(消息)。

对于值,我们将架构传递给 AVRO 序列化器,序列化器从架构注册表中获取它的架构 ID,并将架构 ID 与我们传递的值(消息)一起嵌入(如果我错了,请纠正我)。钥匙怎么办?

我们还需要传递一个键模式吗?传递密钥模式的重要性是什么?而且,如何传递密钥模式?

Rob*_*att 5

Kafka 消息是键/值对。您设置的密钥取决于您和您正在实施的要求。

消息键用于分区分配。通常,您会根据您希望进行的处理以及您想对数据强加的任何严格顺序来键入消息。例如,如果您希望在同一个消费者组中有多个并行进程,并且每个进程接收给定客户的所有记录,那么您需要输入客户 ID。