我有一个使用confluent schema registry的Kafka producer。我知道有一种算法,基于该算法,KafkaAvroSerializer
从confluent schema registry中找到匹配的schemaId(或在注册schema后获取它),以便将其包含为wire格式的一部分。
有没有一种方法可以让我访问由生产者添加到消息中的特定模式ID?
我有一个使用confluent schema registry的Kafka producer。我知道有一种算法,基于该算法,KafkaAvroSerializer
从confluent schema registry中找到匹配的schemaId(或在注册schema后获取它),以便将其包含为wire格式的一部分。
有没有一种方法可以让我访问由生产者添加到消息中的特定模式ID?
1条答案
按热度按时间anauzrmj1#
您可以使用
CachedSchemaRegistryClient
类执行HTTP查找以获取ID。否则,您可以使用ByteBuffer
字符串