如何访问Kafka producer使用的confluent registry schema id？

ep6jt1vc 于 5个月前发布在 Apache

关注(0)|答案(1)|浏览(78)

我有一个使用confluent schema registry的Kafka producer。我知道有一种算法，基于该算法，KafkaAvroSerializer从confluent schema registry中找到匹配的schemaId（或在注册schema后获取它），以便将其包含为wire格式的一部分。
有没有一种方法可以让我访问由生产者添加到消息中的特定模式ID？

apache-kafka

来源：https://stackoverflow.com/questions/77445098/how-to-get-access-to-the-confluent-registry-schema-id-used-by-kafka-producer

1条答案

按热度按时间

anauzrmj1#

您可以使用CachedSchemaRegistryClient类执行HTTP查找以获取ID。
否则，您可以使用ByteBuffer

Serializer s = new KafkaAvroSerializer();
s.configure(...); // give properties like registry url 
byte[] value = s.serialize(record); // example

ByteBuffer bb = ByteBuffer.wrap(value);
bb.get(); // magic byte
int schemaId = bb.getInt();

字符串

赞(0）回复(0）举报 5个月前

我来回答

如何访问Kafka producer使用的confluent registry schema id？

1条答案

相关问题

热门标签

最新问答