我在文档中看到，KSQL通过Confluent Schema注册表支持Avro格式。但是如果正在使用Apache Kafka (而不是Confluent平台)呢？有没有不使用模式注册表的情况下使用Avro SpecificRecord模式的选项？
浏览 26提问于2019-02-19得票数 0
我已经为Kafka 11.4.0安装了IIDR CDC。是否必须使用Confluent包，或者是否可以使用CDC直接连接到我的Kafka实例？
浏览 5提问于2019-11-23得票数 0
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.so
浏览 0提问于2018-03-18得票数 0
我使用汇合卡夫卡设置卡夫卡在一个DigitalOcean液滴上。我能够成功地运行Kafka并使用Kafka添加HDFS连接器。我用我的HOST_IP液滴的IP代替了。Connect时，在任务下的JSON响应中收到以下错误(服务的状态正在运行，但任务已失败)：
io.confluent.kafka.serializers.subject.TopicNameStrategy不是io.confl
浏览 1提问于2018-08-18得票数 1
TL/DR:我在Kafka中有一个Protobuf格式的主题中的数据，我想创建一个流，将protobuf转换为Avro格式的新主题，一旦它转换为avro格式，我将有一个连接器来使用它并将其转储到s3存储桶中，我的SearchRequest ksql流是否需要所有字段，或者我是否可以这样做？，我正在尝试
浏览 22提问于2020-09-19得票数 0
当我们通过KSQL创建AVRO消息并尝试使用Kafka来使用它们时，会发生一些奇怪的事情。有一点背景：
源数据第三方提供商正在我们的一个卡夫卡集群上生成数据，作为JSON (到目前为止，非常好)。Data transforms 由于我们的内部系统需要用AVRO编码数据，我们创建了一个KSQL集群，通过在KSQL中创建以下流将传入的数据转换为<em
浏览 1提问于2019-10-31得票数 0
回答已采纳
嘿，我正在做KSQL快速入门的例子。问题是我想使用avro格式生成数据，但它抛出了我在底部列出的错误。:5.4.0docker run --network tutorials_default --rm --name datagen-users \quickstart=users \ topic=users \
浏览 0提问于2020-06-06得票数 0
我正在尝试生成Confluent的Kafka虚拟数据生成器消息给Elasticsearch：.(io.confluent.connect.elasticsearch.ElasticsearchSinkTask:179)
但是，如果我使用控制台生成器( console producer，./bin/kafka-avro-console-produ
浏览 0提问于2018-11-01得票数 0
回答已采纳
我对kafka是个新手，我对Confluent平台很好奇。在Confluent平台上似乎没有太多的用户故事。Confluent平台和Apache Kafka有什么不同？
浏览 2提问于2016-09-26得票数 49
回答已采纳
我已经在AWS上建立了一个合流平台。我的源是MySql，我使用debezium连接器将其连接到Kafka connect。来自源的数据格式为JSON。现在在KSQL中，我已经创建了一个派生主题，并将JSON主题转换为AVRO，以便可以使用JDBC连接器将数据转换到MYSQL。;
我曾尝试直接使用JSON消息来接收mysql，但失败了，因为连接器需要模式，所以带模式的</em
浏览 26提问于2019-07-10得票数 0
我已经在这个问题上挣扎了大约一个星期，试图获得一个简单的(3个字段) AVRO格式的KSQL表作为JDBC连接器接收器(mysql)的源[2018-12-11 18我可以断定接收器正在正确地执行某些操作(参见上面的错误之前)，并且使用正确的模式在数据库中成功地创建了表：
MariaDB [dsb_errors_ksql]> describe DSB_E
浏览 2提问于2018-12-12得票数 0
我正在使用ksql cli开发confluent-4.1.1。我是否可以在此版本中创建嵌套avro数据格式的流，就像我在版本5中尝试的那样，它工作得很好，但在confluent-4.1.1中提到的嵌套avro模式中找不到有用的链接
我尝试用(kafka_ new_order=‘transition’，value_format=‘
浏览 0提问于2018-10-16得票数 0
我使用将数据从apache复制到AWS S3。
问题是，我有AVRO格式的Kafka数据，它没有使用合流模式注册表的Avro序列化程序，而且我不能更改Kafka生产者。因此，我需要从Kafka反序列化现有的Avro数据，然后在AWS S3中以拼花格式保存相同的数据。我试着用confluent<
浏览 1提问于2020-01-14得票数 1
回答已采纳
1回答
我的步骤: 1.创建从JSON到AVRO的KSQL流 CREATE STREAM source_json_pressure timestamp BIGINT, ) AS 在这之后我得到了阿夫罗流：
浏览 0提问于2019-04-23得票数 1
回答已采纳
2回答
反序列化Avro消息
、、、、
连接器的设置： "name": "from-kafka-to-pg",
2020-02-01 21:16:11,750在任务到-pg-0任务中遇到错误.使用类io.confluent.connect.avro.Avro转换器执行阶段'
浏览 0提问于2020-02-01得票数 3
回答已采纳
1回答
kafka stream / Ksql是否实际上以某种方式支持json？支持的其他格式是什么？我已经看到，是否有可能把扁平的json解释为桌子。我想更好地理解这一部分；通过Ksql可以通过SQL查询kafka-streams的其他格式是什么？这是怎么可能的或支持的？本地的支持是什么？
浏览 0提问于2019-07-02得票数 2
回答已采纳
1回答
作为我最后学习项目的一部分，我将做一个大数据流传输项目，我将使用apache kafka原生，现在我将使用KSQL我的问题是:有没有一种方法可以在不经过confluent平台或docker的情况下安装ksql ?我的意思是我想直接在windows10上安装ksql。
浏览 54提问于2021-08-25得票数 0
回答已采纳
我已经检查了两个类似的问题，但它没有帮助。emailfilters\n\tatretrieving Avro schema for id 21\nCaused by:
io.confluent.<e
浏览 2提问于2018-04-17得票数 0
我把docker和kafka和clickhouse一起使用。我想用'KsqlDB connect‘连接'kafka table’和'clickhouse‘。connection.url"= "jdbc:clickhouse://clickhouse:8123/default", } ('S3_FINAL‘主题具有多键和值的
浏览 724提问于2021-11-02得票数 0
回答已采纳
我使用的是ksqlDB版本5.3.2！当我尝试在ksql CLI中执行此查询时：'connector.class'='io.confluent.connect.hdfs3',
'value.converter'='io.confluent.connect.avro.AvroConverter
浏览 8提问于2020-01-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
