架构注册表中的递归avro架构类型
是指在Avro架构注册表中使用递归结构的数据类型。
Avro是一种数据序列化系统，用于在大规模数据处理系统中进行高效数据交换。它使用JSON格式定义数据结构，并支持多种编程语言。Avro的架构注册表用于管理和存储Avro架构，以便在数据交换过程中进行校验和版本控制。
递归avro架构类型是指一个Avro架构类型定义中包含对自身的引用。通过递归结构，可以创建复杂的数据结构，如树形结构或图形结构。
递归avro架构类型的优势在于可以表示具有动态深度的数据结构，并允许灵活地处理复杂数据关系。它可以用于构建具有嵌套关系的数据模型，如文件系统、组织结构、社交网络等。
递归avro架构类型的应用场景包括：
- 文件系统：递归结构可以用于表示文件和文件夹的层次结构，方便文件管理和访问。
- 组织结构：递归结构可以用于表示组织的层次结构，如部门和子部门之间的关系。
- 社交网络：递归结构可以用于表示社交网络中用户之间的关系，如好友、粉丝等。
- 数据库关系：递归结构可以用于表示数据库中具有父子关系的表，如员工和上级之间的关系。
腾讯云提供的相关产品和服务中，推荐使用腾讯云消息队列 CMQ（Cloud Message Queue）来处理递归avro架构类型的消息传递和数据交换。CMQ是一种分布式消息队列服务，提供高可靠、高可扩展的消息传递能力，适用于各种场景下的消息通信。您可以在以下链接中了解更多关于腾讯云消息队列 CMQ的信息：
相关·内容
我们使用的是Kafka，Avro和Avro模式注册表。给定我想要使用的一组主题，是否有一种方法可以获得所有模式I，以解码我将收到的消息？
我检查了Confluent的Python的实现，它似乎是接收消息，从单个消息获取Avro，然后从Avro动态查找模式。
我正在寻找一种方法，在程序的执行之前(即手动)获得所需的所有模式。
浏览 1提问于2018-06-06得票数 1
在NiFi中，我首先将JSON转换为Avro，然后再从Avro转换为JSON。但在从Avro转换到JSON时，我遇到了异常。
从Avro转换到JSON时，我得到了以下异常：
2019-07-23 12:48:04,043 ERROR [Timer-Driven Process Thread-9] o.a.n.processors.avro.ConvertAvroToJSON ConvertAvroToJSON[id=1db0939d-016c-1000-caa3-80d0993c3468] ConvertAvroToJSON[id=1db0939d-016c-1000-caa3-80d0993
浏览 0提问于2019-07-23得票数 0
1回答
我有一个XLS/CSV文件，我正在将其读取到pandas数据帧中。我想从这个数据帧中生成一个avro模式。
我对python和熊猫都是新手。请帮帮忙。
data_frame = pd.read_excel(INPUT_PATH)
我想从这个数据框中动态生成一个avro模式。请帮帮忙
浏览 14提问于2019-10-21得票数 1
回答已采纳
1回答
对不起，这是个初学者的问题。
我的Java微服务接受一个包含模式版本元素的有效负载请求，可以有许多不同版本的有效负载，每个版本的格式略有不同。是否可以使用该版本号对AVRO模式注册表进行查找，然后使用该模式验证所接收的有效负载。
这是一个有效和可能的AVRO用例吗？
然后，我们的目的是在Java微服务中处理这些数据，然后再继续发送。
也许AVRO不是正确的技术，但如果不正确，请告知。
浏览 2提问于2018-07-18得票数 4
回答已采纳
我正在使用nifi构建一个数据流，其设置如下：
apache nifi 1.14.1
卡夫卡2.13-2.7.1
合流模式注册表
我还使用处理器ConsumeKafkaRecord_2_6处理来自一个主题的消息，在这个主题中，键和值都使用avro模式对键和值进行序列化，都存储在汇合模式注册表中。但是处理器无法解析消息，因为没有一种方法--我可以看到--指定键和值都是用存储在汇合模式注册表中的模式序列化的。命名架构的约定通常是主题名称-值和主题名称-键。使用kcat，以前使用kafkacat，我可以很好地读取消息：
kcat -b broker1:9092,broker2:9
浏览 16提问于2022-02-18得票数 0
回答已采纳
我想从弗林克州立大学出来和卡夫卡汇合。在中，为了进行模式检查并将数据放入到kafka主题中，我们所需要做的就是使用kafka客户端ProducerRecord对象和avro对象。
但是在中，我们需要重写卡夫卡出口的"ProducerRecord<byte[]，byte[]>序列化“方法。这将导致以下错误。
Caused by: org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: "bytes"
模式登记和国家-卡夫卡出口似乎是不相容的。有什
浏览 6提问于2020-06-22得票数 0
回答已采纳
1回答
我已经在模式注册表中注册了一个模式，我可以这样使用register()，
from schema_registry.client import SchemaRegistryClient, schema
subject_name = "new-schema"
schema_url = "https://{{ schemaRegistry }}:8081"
sr = SchemaRegistryClient(schema_url)
schema = schema.AvroSchema({
"namespace": "exampl
浏览 0提问于2020-05-21得票数 2
回答已采纳
说明Avro和服务注册中心使用情况的大多数Quarkus示例将消费者和生产者结合在同一个项目中。在这样做时，模式和生成的类对生产者和使用者都是可用的。
我理解模式注册中心的作用是维护模式的各种版本，并将它们提供给消费者。
我不完全理解的是使用者如何以及何时从注册表中提取模式。例如，使用者的团队如何获得模式的初始版本？他们只是去注册表并手动下载吗？他们是否使用maven插件下载并生成源代码？
对于Quarkus，avro扩展将自动从avro模式生成Java源。我想知道它是否也为消费者下载了初始模式。
浏览 10提问于2022-07-23得票数 0
我想知道我是否可以使用合流模式注册表生成(然后将其发送到kafka)模式，而不是avro记录？如果是的话，谁能分享一些资源吗？我无法在汇合网站和谷歌上找到任何例子。
我有一个普通分隔的文件，并且有一个单独的模式，目前我正在使用Avro通用记录模式来序列化Avro记录并通过Kafka发送它。这样，模式仍然与记录相关联，这使得它更加庞大。我的逻辑是，如果我删除模式，同时从kafka发送记录，我将能够获得更高的吞吐量。
浏览 1提问于2017-07-13得票数 0
回答已采纳
我已经检查了两个类似的问题，但它没有帮助。
node 1 [/appl/node1/confluent-4.0.0] ./bin/confluent status elasticsearch-sink
{"name":"elasticsearch-sink","connector":{"state":"RUNNING","worker_id":"10.192.226.24:8083"},"tasks":[{"state":"FAILED&#
浏览 2提问于2018-04-17得票数 0
1回答
我们使用Kafka消息的无注册Avro模式，所以我们有我们的自定义Avro转换器，因为我们没有可用的模式注册表
问题是，当我们使用新元素升级模式时，旧模式不是向后或向前兼容的
浏览 1提问于2021-05-31得票数 0
在我的Spark streaming工作中，我试图从Kafka主题中读取Confluentavro消息，并获得“在记录解析中检测到错误的记录”。
我试着调试了很多次，但还是找不出错误的记录。需要帮助理解如何从格式错误的行中获取记录。有没有一种方法可以打印avro消息，以查看消息有什么问题。
我的代码：
object AvroReadMessage extends App {
val spark = SparkSession.builder.master("local[*]").appName("AvroReadMessage")
.getOrCreate
浏览 0提问于2019-12-16得票数 0
1回答
我有一个应用程序，它周期性地用原始JSON生成一系列消息。我可以用Avro工具把它转换成avro。我这样做是因为由于Kafka接收器的限制，我需要消息包含模式。我可以在notepad++上打开这个文件，并看到它包括模式和几行数据。
现在，我想将它发送给我的中心Kafka代理，然后使用Kafka接收器将数据放入数据库。我很难理解我应该如何将这些阿夫罗文件发送给我的卡夫卡经纪人。我是否需要一个模式注册表来实现我的目的？我相信Kafkacat不支持Avro，所以我想我必须坚持卡夫卡-生产者. so的卡夫卡安装(请纠正我，如果我错了)。
问题是:能否有人分享步骤，以生产我的Avro文件给一个卡夫卡经纪
浏览 3提问于2021-03-31得票数 0
回答已采纳
我有一个定义如下的消费者。它读取主题外的avro消息，并构造一个聚合数据的状态存储，该数据也是avro类型的。
@Bean
public Consumer<KStream<String, InputEvent>> avroTest() {
Serde<OutputEvent> serdeOutEvent = new SpecificAvroSerde<>(schemaRegistryClient);
return st -> st.groupByKey().aggregate(OutputEv
浏览 23提问于2021-02-27得票数 1
回答已采纳
我需要记录到达Kafka使用者的消息，因为对于Kafka消费者，没有Avro模式兼容性。
我怎样才能做到这一点？
我想，默认情况下，Avro不兼容的消息永远不会到达我的Kafka消费者代码。我使用Spring的@KafkaListener。
浏览 11提问于2021-12-07得票数 0
1回答
我想注册一个Avro模式，它引用模式注册中心上的另一个Avro模式。
首先，我注册了以下基本Avro模式：
{
"type":"record",
"name":"Client",
"namespace":"com.test.client",
"doc": "Client Property specific information is specified in this object",
"fields" : [
{&#
浏览 1提问于2020-11-27得票数 0
回答已采纳
我已经创建了一个NiFi流，它最终将json记录发布为带有Avro编码值和字符串键的记录，使用模式中的模式。这是 in NiFi。
我现在试图使用Kafka (connect-standalone)使用JdbcSinkConnector将消息移动到PostgreSQL数据库，但得到了以下错误：
我已经确认我的为1的架构。
Worker Config:
bootstrap.servers=localhost:29092
key.converter.schemas.enable=false
key.converter=org.apache.kafka.connect.storage.StringC
浏览 0提问于2018-12-11得票数 0
回答已采纳
1回答
带有模式的Avro消息
、、、、
因此，我们计划使用Avro在一个以卡夫卡为基础的合流生态系统上进行交流。我目前对Avro的理解是，每条消息都包含其模式。如果是这样的话，我们需要模式注册表来解析版本更新吗？
我问您，因为携带每条消息的模式可以防止需要模式注册中心将消息id映射到模式。还是我在这里漏掉了什么？
浏览 5提问于2017-05-30得票数 1
回答已采纳
1回答
我目前无法在KSTREAM应用程序中反序列化avro原语键
使用avro模式编码的键(在模式注册表中注册)，
当我使用kafka-avro--使用者时，我可以看到关键是正确地反序列化。
但不可能让它在KSTREAM应用程序中工作
键的avro模式是一个原语：
{"type":"string"}
我已经跟踪了汇合式的文档
final Serde<V> valueSpecificAvroSerde = new SpecificAvroSerde<>();
final Map<String, String> serdeConfig
浏览 0提问于2019-07-26得票数 0
回答已采纳
在我们分发给工人的道具中，我们有：
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=<dev-schema-url>
我们已经注意到，当我们使用模式注册中心时，性能是不好的。如果没有模式注册中心，我可以使用AvroConverter吗？我试过，但我们遇到了：
java.io.IOException Not a data file
模式注册表是否与kafka连接器读取的每一条消息相联系？
模式缓存了吗？
在没有模式注册中心的情况下使用A
浏览 1提问于2019-01-23得票数 4
1回答
我试图了解如何使用与卡夫卡绑定的Spring流。
目前，我正试图在我的AVRO schema中注册一个Confluent Schema Registry，并将消息发送到某个主题。
我无法理解Spring Cloud Streams是如何在幕后完成模式注册的。
让我们从Stream示例中获取。
AVRO架构位于src/resources/avro中。
当运行mvn:compile目标时，将生成AVRO模式的POJO，并且生产者可以发布数据。
但是，我无法理解Stream是如何对AVRO进行模式注册的？
@Autowired
StreamBridge streamBridge;
浏览 0提问于2021-09-20得票数 1
回答已采纳
Apache Avro能否在序列化期间处理参数化类型？
当我尝试序列化一个使用泛型的实例时，我发现Avro框架抛出了这个异常。
org.apache.avro.AvroTypeException: Unknown type: T
at org.apache.avro.specific.SpecificData.createSchema(SpecificData.java:255)
at org.apache.avro.reflect.ReflectData.createSchema(ReflectData.java:514)
at org.apache.avro.ref
浏览 7提问于2015-02-23得票数 3
1回答
我试图使用函数编程(和spring云流)从输入主题转换输入AVRO消息，并在输出主题上发布新消息。这是我的转换函数：
@Bean
public Function<KStream<String, Data>, KStream<String, Double>> evenNumberSquareProcessor() {
return kStream -> kStream.transform(() -> new CustomProcessor(STORE_NAME), STORE_NAME);
}
CustomProcessor是一个实现“转换
浏览 5提问于2021-04-06得票数 1
随着迁移到汇流v4.0，的flush.size不再适用于我了。它与Contentv3.x一起工作。
这是当前的配置文件：
name=my-job-name
connector.class=io.confluent.connect.hdfs.HdfsSinkConnector
tasks.max=1
topics=my-topic-name
hdfs.url=hdfs://my/path
hadoop.conf.dir=/etc/hadoop/conf/
flush.size=50000
#rotate.interval.ms=80000
当我开始这项工作时，它会在HDFS中生成数百万个小的
浏览 0提问于2018-01-29得票数 1
回答已采纳
我试图使用Avro模式向代理发送一条消息，但是“我总是收到错误：
2020-02-01 11:24:37.189 nioEventLoopGroup-4-1错误应用程序-未处理: POST - /api/orchestration/ org.apache.kafka.common.errors.SerializationException:错误注册Avro模式: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:模式所导致的“io.confluent.kafka.schemaregistr
浏览 1提问于2020-02-01得票数 5
回答已采纳
我使用的是合流模式注册表。
Avro与Cloudevent Vs AsyncAPI的区别是什么？
卡夫卡的模式演变和命名约定最适合什么？
我们可以根据需求为不同的主题使用不同的模式类型吗？
浏览 14提问于2020-03-18得票数 3
回答已采纳
对卡夫卡来说是非常新的，并且对多个教程感到非常困惑。是否需要设置任何kafka avro的模式注册表？如何设置一个弹簧启动-卡夫卡项目。
浏览 4提问于2020-06-15得票数 0
回答已采纳
1回答
我试图在Ubuntu上运行一个星火流应用程序，但是我遇到了一些错误。由于某种原因，Ubuntu22.04没有找到jar文件，尽管Windows上的配置是相同的。
我在脚本中运行以下配置
spark = SparkSession \
.builder \
.appName("File Streaming PostgreSQL") \
.master("local[3]") \
.config("spark.streaming.stopGracefullyOnShutdown",
浏览 6提问于2022-08-15得票数 0
回答已采纳
1回答
背景:我使用SpringKafka来实现基于Avro的消费者和生产者。其他重要组件: Kafka-Broker、Zookeeper和Schema-注册表在码头容器中运行。这对我来说很好。
我想要的是:我想要一个Kafka Avro反序列化器(在使用者中)，它应该独立于模式注册中心。在我的例子中，我有一个不会更改的avroSchema文件。因此，我想摆脱在消费者端使用模式注册中心这一额外步骤，而是选择本地模式文件。
浏览 9提问于2022-04-26得票数 0
回答已采纳
1回答
我试图将Avro和Schema集成到Kafka数据管道中。现在它看起来在Go服务的内部
获取数据->将数据编码为JSON ->写入卡夫卡
我想以同样的方式使用avro模式。
在模式注册表中生成模式->更新模式->获取数据->编码到Avro ->写入
但是有几个问题：
如何从Go类自动生成模式？
如何检查模式与模式注册表的兼容性？
浏览 1提问于2018-06-01得票数 2
嘿，我正在做KSQL快速入门的例子。问题是我想使用avro格式生成数据，但它抛出了我在底部列出的错误。
该教程位于
复制问题
git clone https://github.com/confluentinc/ksql.git
cd ksql
git checkout 5.5.0-post
cd docs/tutorials/
docker-compose up -d
如果您停靠ps，您应该看到以下容器正在运行：
confluentinc/ksqldb-examples:5.5.0
confluentinc/cp-ksql-server:5.4.0
confluentinc/cp-sch
浏览 0提问于2020-06-06得票数 0
2回答
我没有确切的键模式的概念，它是什么，为什么它必须用作键是自动生成的，我们只是传递一个值(消息)。
对于值，我们将一个模式传递给AVRO Serialiser，然后序列化器从模式注册表中获取它的模式id，并将该模式id与我们传递的值(Message)一起嵌入(如果我错了，请纠正我)。key会发生什么？
我们还需要传递密钥架构吗？传递密钥模式的重要性是什么？那么，如何传递密钥模式呢？
浏览 1提问于2018-03-08得票数 4
我想使用apache在kafka主题中生成一些通用数据，我希望这些数据是avro格式的。我为它所做的：
在模式注册表中创建新模式：
{“类型”：“记录”、“名称”："my_schema“、”命名空间“："my_namespace”、"doc"："“、”字段“：[{ "name"："key”、"type"："int“}、{ "name"："value"，"type"："null"，"int“}，{ "name"
浏览 1提问于2018-10-09得票数 1
回答已采纳
我正在研究Kafka，作为一个初学者，下面这个问题突然出现在我的脑海中。
每次我们为Avro设计模式时，我们都会通过它的jars从它创建Java对象。
现在，我们使用该对象来填充数据并从生产者发送数据。
为了使用消息，我们在Consumer中再次生成对象。现在，在Producer和Consumer这两个位置生成的对象包含一个字段
"public static final org.apache.avro.Schema SCHEMA$“，实际上将模式存储为字符串。
如果是这样的话，为什么kafka要使用模式注册表呢？该模式已经作为Avro对象的一部分可用。
希望我的问题是清楚的。如果有人能
浏览 0提问于2018-04-02得票数 0
4回答
加缪-卡夫卡的例子
、、、
我的用法是我想把Avro数据从Kafka推到HDFS。加缪似乎是正确的工具，但我无法使它工作。我是加缪的新手，试着让加缪--例子，
现在我正试着让加缪的例子发挥作用。然而，我仍然面临着一些问题。
用于DummyLogKafkaProducerClient的代码片段
package com.linkedin.camus.example.schemaregistry;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.uti
浏览 6提问于2014-12-31得票数 2
我正在尝试使用connect MongoDB kafka连接器接收器( MongoDB Connec-MongoDB-1.7.0)将avro事件从kafka写到MongoDB。
我已经设置了一个模式注册中心，它可以与kafka消费者示例或我的自定义示例一起工作，它们都可以反序列化事件并打印它们。
另一方面，当我运行连接器时，我会得到以下异常：
Subject '<my-avro-schema-name>-value' not found.; error code: 40401
更高级别的堆栈跟踪消息是：
由: org.apache.kafka.common.erro
浏览 4提问于2022-04-13得票数 0
我最近开始探索卡夫卡和卡夫卡的联系，并做了一些初步的设置。但是想了解更多关于模式注册部分的内容。
我的模式注册中心现在已经启动，我应该做什么。
我在avro_schema.avsc中存储了一个AVRO模式。
这是一个模式
{
"name": "FSP-AUDIT-EVENT",
"type": "record",
"namespace": "com.acme.avro",
"fields": [
{
"name": "ID&
浏览 1提问于2020-01-06得票数 3
我的Avro记录类型中的一个字段(abc )最初是强制性的，我试图将其更改为允许空值，但我得到了以下错误：
io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:
Schema being registered is incompatible with an earlier schema for subject.
details: [Incompatibility{type:TYPE_MISMATCH, location:/, message:reader type:
RECORD not
浏览 5提问于2022-08-10得票数 0
我试图使用Postgres接收器连接器将json消息加载到Postgres数据库中。我一直在线阅读，并且只找到了在JSON消息中使用模式的选项，但是，理想情况下，我不希望在消息中包含模式。有没有一种方法可以在模式注册表中注册JSON模式并像使用Avro那样使用它？
另外，我目前正在通过下载bin运行kafka，因为由于ARM兼容性问题，我在运行kafka与坞连接时遇到了几个问题。模式注册表是否有类似的安装？因为我只能选择通过汇流下载它并在码头上运行它。是否可以只运行带有docker的架构注册表，保持当前的设置？
谢谢
浏览 2提问于2022-01-31得票数 0
我正在尝试使用以下命令启动kafka-connect：
connect-distributed /etc/schema-registry/connect-avro-distributed.properties
，但是我得到了：
[2017-02-15 12:45:35,962] INFO Instantiated task mysql-adventureworks-source-0 with version 3.1.2 of type io.confluent.connect.jdbc.source.JdbcSourceTask (org.apache.kafka.connect.runtim
浏览 18提问于2017-02-15得票数 1
1回答
我为一个主题生成相同的Avro模式，使用不同的。当我使用这个主题时，我会得到错误：
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition XXXXX_XXXX_XXX-0 at offset 0. If needed, please seek past the record to continue consumption.
Caused by: org.apache.kafka.common.errors.SerializationException
浏览 0提问于2020-01-09得票数 0
回答已采纳
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.someapp:8080/ksql -H "Content-Type: application/json" -d $'
{"ksql": "CREATE STREAM kawabanga_stream (lo
浏览 0提问于2018-03-18得票数 0
有没有一种方法可以将AZURE模式注册表与Spark结构化流一起使用？(不是开源模式注册表)。
理想情况下，我应该使用一些高级库，比如Abris ()，通过在模式注册表中自动注册/读取df模式，从/写avro到Kafka。但是，我根本没有找到任何能够让Schema对执行to_avro或from_avro操作的东西。
有一个开放的PR可以为某些列类型添加功能
似乎有一种未维护的回购至少尝试了from_avro部分()。
谁知道一个好的方法，如何与Azure模式注册表与星火结构化流交互？
浏览 15提问于2022-05-28得票数 0
我设置了一个Kafka接收器来将事件发送到PostgreSQL。我编写了这个简单的生成器，它向主题发送带有模式(avro)数据的JSON，如下所示：
producer.py (kafka-python)
biometrics = {
"heartbeat": self.pulse, # integer
"oxygen": self.oxygen,# integer
"temprature": self.temprature, # float
"time": time
浏览 2提问于2021-02-14得票数 0
回答已采纳
我想在kafka上生成avro类型的消息。有没有一种方法可以使用在模式注册表中注册的模式id而不是指定模式？
浏览 12提问于2020-11-20得票数 0
1回答
我是kafka的新手，.Here是我对不断变化的kafka模式的疑问。
我们如何在kafka消费者端处理模式更改？
如果我们在kafka publisher端更改负载结构，我如何确保kafka消费者端不会中断？
我很有兴趣知道全行业的实践来处理这种情况。
我不会为avro使用Confluent的模式注册表。还有没有其他经过试验和测试的选项？
浏览 0提问于2020-04-26得票数 0
我正在尝试使用Confluent中的rest代理API更新avro模式。我可以使用以下内容执行GET，并获得有效的响应：
但是当我尝试这个的时候：
使用POST、PUT或PATCH，我总是得到
{"error_code":404,"message":"HTTP 404 Not Found"}
我也尝试过，但它产生了以下结果：
{"error_code":405,"message":"HTTP 405 Method Not Allowed"}
我已经询问了运营团队，他们不相信特定的动词是启用/禁用的
浏览 0提问于2020-02-15得票数 0
我试图建立一个简单的卡夫卡堆栈在当地，我是在点，我需要创建一个玩具生产商。这是： (我感兴趣的代码见下面)几乎就是我想要的，除了：
在这里，生产者发送一个GenericData.Record对象，因此整个模式被发送，并且它不利用模式注册表。我想发送一个ArrayByte，其中前几个字节是模式的id，下面的字节是数据，没有模式(所以我认为这是最好的方法)。
我说的代码是：
import java.util.Properties
import org.apache.avro.Schema.Parser
import org.apache.avro.generic.GenericData
impo
浏览 0提问于2021-01-12得票数 0
回答已采纳
2回答
我需要将JSON消息转换成Avro，这样我才能将它发送给Kafka。
我有示例JSON请求，还有Avro的avsc文件中的模式。
你知道我怎么能做到吗？
谢谢
浏览 16提问于2022-02-06得票数 0
2回答
Hive提供了两个表属性，允许定义Avro：avro.schema.literal和avro.schema.url，前者可以指定为模式服务的hdfs路径或http端点。我想使用作为我的模式服务，但问题是它的返回模式封装在一个更大的json对象中：
请求：
GET /schemas/ids/1
响应：
HTTP/1.1 200 OK
Content-Type: application/vnd.schemaregistry.v1+json
{
"schema": "{\"type\": \"string\"}"
}
请求：
GE
浏览 3提问于2017-06-06得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
