Key3": "6",
{ "Key2": "8", ]
} 我已经编写了KSQLstreams来将其转换为AVRO并保存到一个主题，这样我就可以将其推送到JDBC Sink连接器 CREATE STREAM Example1(ArrayObj ARRAY<STRUCT<
浏览 22提问于2019-12-21得票数 3
我正在使用Kafka将一些数据传输到Kafka。我可以使用print 'kdc-01-orders' from beginning;查看这些数据。数据看起来是正确的JSON。:58)ksql-server_1 |
浏览 0提问于2019-07-02得票数 2
我有apache访问日志文件，我想在cassandra表中存储每个页面的访问计数(总数/每天/每小时)。
我正在尝试使用kafka连接从日志文件流到kafka主题。为了在Cassandra中增加指标计数器，我可以再次使用Kafka Connect吗？否则，这里应该使用哪些其他工具，例如kafka streams，spark，flink，kafka connect等？
浏览 0提问于2017-10-11得票数 0
我刚接触Apache Kafka和它的与API相关的流服务，但想知道是否有任何正式的文档来获取摄取所需的初始原始数据？从本质上讲，我想尝试构建一个初级的密码交易机器人，但我的印象是http API可能比与Kafka Streams集成的API具有更多的延迟。例如，我知道RapidAPI有一个可以访问的http库，可以帮助提取数据，但我不确定如果我想通过Kafka Streams摄取数据，是否有类似的东西。我猜我的印象是，这两个数据源不会相似，在某种程度
浏览 0提问于2021-06-05得票数 0
我正在尝试在基于sourceTopic1和sourceTopic2的targetTopic1中创建数据。这两个源主题应该具有相同的事件结构。首先创建目标流，然后尝试从另一个源流向当前流插入数据。ksql> CREATE STREAM sourceTopic1Stream (category varchar, source varchar, type varchar, id varchar, payload%';
--------------------
浏览 3提问于2018-11-06得票数 1
我们的系统中也有很多消费者。在投放给消费者之前，有没有过滤广告的方法？我的解决方案是将所有内容写入第一个主题，然后由筛选器使用者读取它，然后将其写回第二个主题或对其进行筛选。但我不确定它是否有效。
浏览 33提问于2015-06-18得票数 14
回答已采纳
1回答
我对从SQL Server加载数据到Kafka感兴趣。表中的一列是XML one。如何在KSQL streams中将XML转换为JSON或AVRO共振峰？
浏览 9提问于2020-02-05得票数 1
实体X包含另一个实体Y的外键
我的问题是，是否有一个有效的方法来做到这一点与卡夫卡流库或KSQ
浏览 0提问于2022-01-08得票数 0
回答已采纳
1回答
在调用KSQL端点以执行查询时，我面临问题，我的查询是：我把它寄出在邮件请求的正文中如下：
有时它在1秒内响应，有些时候它在5秒内响应，一些时间在10秒内流中有较大的<em
浏览 1提问于2018-11-08得票数 0
我有一个场景，在消息到达kafka之前，我需要更改从JDBC源连接器获得的消息结构。我是kafka的初学者，所以kafka streams如何帮助我实现这一点。输入-我想将其存储在弹性索
浏览 0提问于2018-09-21得票数 0
我想创建一个Storm Spout，它从Apache Kafka的主题中读取数据，并将这些数据发送到连接到MongoDB的Storm bolt，并查询我从Kafka收集的消息以丰富数据。例如:我有一个personID (我是通过Kafka发来的消息得到的)，我想使用这个personID查询MongoDB中的个人地址。在我的MongoDB集合中，每个文档都有personID和地址。
浏览 0提问于2018-04-18得票数 0
我使用Debezium MySql连接器将数据库更改事件从MySql数据库流式传输到Kafka。我需要将特定的转换应用于某些指定表(而不是其他表)中的记录。有没有一种只使用Kafka Connect单消息转换(没有Kafka Streams或KSQL)的方法？我甚至不介意写一个自定义的SMT。但我找不到如何为消息指定要应用SMT的表/主题。谢谢。在简短的调查之后，我决定使用KSQL。感谢大家的回答
浏览 10提问于2019-04-11得票数 1
我希望使用火花结构流从卡夫卡读取数据，并处理它，并写入蜂窝表。xxxxxxx") .awaitTermination()
这确实创建了一个parquet文件，但是我如何将其更改为类似的内容，以便将其写入可使用(select * from)从hive
浏览 5提问于2018-02-06得票数 1
1回答
是否有一种方法来指定运行在KSQL上的KSQL查询应该使用的线程数？换句话说，查询的并行性。
在KSQL上可以运行的应用程序数量是否有任何限制？何时或如何决定扩大规模？
浏览 1提问于2019-07-07得票数 2
回答已采纳
对于处理器组件，其目的是读取/使用主题中的数据，对其执行一些处理/ETL，并将结果持久化到链中的下一个主题以及持久存储，如S3。欢迎任何建议/参考。
浏览 1提问于2019-01-03得票数 0
我们有一个使用案例，我们使用Kafka连接到Source和Sink数据。它就像一个典型的ETL。对此有什么更好的方法吗？
浏览 3提问于2017-10-11得票数 0
我使用查询"Create base_stream with“(kafka-topic ="myTopic"，format="avro")创建了一个流，这个主题拥有超过800 of的数据并在不断增长。问题：
是否复制了新流中底层主题中的数据？或者是相同的数据?当KSQL服务器重新启动时，base_stream丢失了其数据。有任何方法来持久化这些数据吗？因为，如果每次KSQL server重新启动时都必须重
浏览 0提问于2020-02-24得票数 0
我目前正在做一个kafka streams的POC，其中我试图使用kakfa作为一个消息总线以及一个数据库。我尝试使用ksql来实现第二个目的。我可以使用ksql查询主题，但这需要很长时间，因为ksql每次都会读取整个主题，然后在客户端对其进行过滤。有没有办法将整个主题物化为kafka中的状态存储？
浏览 18提问于2019-03-12得票数 0
我无法将数据从unable获取到pojo类输出。 json.put("ksqlEQP_STREAM limit 10;");
JSONObject jsonSub = new JSONO
浏览 0提问于2019-04-29得票数 3
我想使用ksqlDB对来自kafka broker上的主题的数据进行一些流处理。docs.confluent.io/platform/current/installation/versions-interoperability.html的兼容性表，我使用的是Confluent Platform V5.2中的我在ksql/ksql-server.properties中设置了bootstrap.servers=<myurl>:9092。'
浏览 43提问于2021-01-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
