1回答
表中的一列是XML one。如何在KSQL streams中将XML转换为JSON或AVRO共振峰？
浏览 9提问于2020-02-05得票数 1
但是，当我转到KSQL时，如果我试图将AVRO流直接沉入InfluxDB，就会丢失有关复杂类型(标记)的信息。我注意到来自这个的警告：“警告ksqlDB/KSQL还不能以与此连接器兼容的Avro格式写入数据”。接下来，我尝试将AVRO流转换为JSON格式，但现在我了解到，我必须在每个记录中指定模式，类似于这个所呈现的模式。我还无法将AVRO流转换为JSON</em
浏览 1提问于2020-05-28得票数 1
1回答
我试图使用avro模式在ksqldb中创建一个流到Kafka中的某个主题。该命令如下所示：主题客户看起来如下PhoneNumbers":"269 xxx-1111"，"269 xxx-2222"，”远程“：false，”身高“：”69.9“，"FicoScore":”> 690
浏览 10提问于2022-09-29得票数 0
回答已采纳
主题A将接收所有json消息并由Avro Schema格式化(使用模式注册中心的URL )。
由于某些原因，我们使用的开发工具不支持从主题A以avro格式接收消息。我们创建主题B，并希望使用KsqlDB将所有消息从主题A复制到主题B，并将所有消息从avro格式转换为普通的json格式，这样我们就可以开发一个可以从主题B获取json消息的组件。请给我看一下代码来创建ksql流来完成这个任务。
浏览 6提问于2022-01-21得票数 0
回答已采纳
我的JSON看起来像这样： { "a": "abc", "c": "ghi" "ArrayObj": [streams来将其转换为AVRO并保存到一个主题，这样我就可以将其推送到JDBC Sink连接器 CREATE STREAM Example1(ArrayObj ARRAY<STRUCT&
浏览 22提问于2019-12-21得票数 3
1回答
我已经将kafka连接到mysql。该主题包含AVRO格式的数据。现在，我想将该数据转换为CSV格式。为此，我使用了KSQL流。当我像这样创建流时(如果我用相同的主题运行消费者命令，它会显示数据)，然后给select * from source_avro，它不会显示任何数据。遵循步
浏览 1提问于2019-04-23得票数 1
我的消息是JSON格式，没有任何附加的模式。io.confluent.connect.jdbc.JdbcSinkConnectortopics=send_1value.converter=org.apache.kafka.connect.json.JsonConverter
value.converter.schemas.enabl
浏览 1提问于2019-10-11得票数 0
我试图构建一个系统，从Kafka读取json数据(模式无模式)，将其转换为avro并将其推送到s3。 avro_Schema.Builder avro_record = avro_Schema.newBuilder()我不确定这是否是正确的方法，但我面临的问题是，当调用newRecord()函数时，它希望u
浏览 1提问于2020-12-31得票数 1
回答已采纳
但是，当我实际尝试将数据发布到我的HDFS实例时，我会收到一个不同的错误。我正在使用ksql-datagen来生成假数据。docker-compose exec ksql-datagen ksql-datagen quickstart=users format=json topic=test_hdfs maxInterval\n", "worker_id": "connect:8083"
浏览 1提问于2018-08-18得票数 1
来自源的数据格式为JSON。现在在KSQL中，我已经创建了一个派生主题，并将JSON主题转换为AVRO，以便可以使用JDBC连接器将数据转换到MYSQL。', VALUE_FORMAT='JSON');create TABLE avro_stream WITH (VALUE_FORMAT='AVRO') AS select * from json_str
浏览 26提问于2019-07-10得票数 0
1回答
在KAFKA中是否有一种方法可以使用XML源并将其转换为JSON并将JSON数据发送给KAFKA接收？
我见过Avro，Protobuf作为卡夫卡连接的转换器？它们是否能够将XML转换为JSON？或者他们会转换为AVRO，Protobuf特定的格式，而不是JSON？
浏览 6提问于2022-03-30得票数 0
TL/DR:我在Kafka中有一个Protobuf格式的主题中的数据，我想创建一个流，将protobuf转换为Avro格式的新主题，一旦它转换为avro格式，我将有一个连接器来使用它并将其转储到s3存储桶中现在假设我有一个格式为protobuf的Kafka主题SearchRequest_proto，然后我想创建一个格式为avro的名为SearchRequest_avro的主题 例如，我的protobuf是-------------------
浏览 22提问于2020-09-19得票数 0
1回答
为此，我必须将csv记录转换为DataModel。我阅读了下面的教程，但无法理解如何用java编写这个教程。那么，这里有人能帮我吗?我如何将csv文件数据转换成数据模型？提前谢谢。
浏览 0提问于2019-04-05得票数 2
1回答
我有一个案例:在流内容中，总是json格式的和，json中的数据总是改变( kyes和values)。是否可以将此流内容转换为csv？非常感谢，
浏览 0提问于2018-09-26得票数 0
当我们通过KSQL创建AVRO消息并尝试使用Kafka来使用它们时，会发生一些奇怪的事情。有一点背景：{
"ksql": "&#x
浏览 1提问于2019-10-31得票数 0
回答已采纳
我有两个越南船民-我试图将connect我将通过下一个docker-组合文件来运行集群：version: '2' zookeeper: -e CONNECT_CONFIG_STORAGE_TOPIC="quickst
浏览 12提问于2022-03-06得票数 1
1回答
VALUE_FORMAT='DELIMITED', VALUE_DELIMITER='|');
--------------------------------ksql> SET 'auto.offset.reset' = 'earliest';
Successfully changed local property 'auto.offset.reset|and
浏览 2提问于2020-03-11得票数 0
嘿，我正在做KSQL快速入门的例子。问题是我想使用avro格式生成数据，但它抛出了我在底部列出的错误。cp-schema-registry:5.4.0,confluentinc/cp-zookeeper:5.4.0 decimal.format = BASE64 (io.confluent.connect.<
浏览 0提问于2020-06-06得票数 0
1回答
Kafka键格式
、、
我的主题之一有一个字符串-json作为键{“城市”：“X”，"id":22}。在我的ksql语句中，我想将它提取到两个不同的字段，而不是一个，这样以后我就可以过滤并加入。在文档中，它似乎允许我只将整个字符串插入键中，而不是允许将其格式化为JSON (就像FORMAT_VALUE一样)，请参见下面.对此有什么建议吗？支持的格式: JSON、定界符和AVRO
KEY Associates将Kafka主题中的消息键与KSQL流中的一列关联起来。
浏览 2提问于2018-04-15得票数 1
回答已采纳
1回答
我有一个structured XML数据。我想用AVRO schema转换这个XML to AVRO(or JSON)。我已经为这个XML定义了AVRO模式。但是怎样才能把它转换成java呢？实际上，我希望将从服务器接收到的xml数据转换为Kafka Connect中的JSON/AVRO格式。做这件事最好的方法是什么？
浏览 4提问于2019-08-09得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
