假设有一个多阶段的请求流，要求具有给定in的文档从源中检索、对比度调整、OCRed、字数统计、放在目标目录中等(具体的阶段可能因请求而异)。请求阶段必须按顺序完成，缓存中的中间结果应该被重用(不要一遍又一遍地保持OCRing相同的文档)。我想为各个应用程序(文档检索应用程序、OCR应用程序等)创建一个请求流。我怎样才能用ksqlDB做到这一点？
浏览 11提问于2020-06-17得票数 0
我想使用KSQL查询将kafka集群中存在的所有主题名称存储到另一个主题中。来自KSQL CLI的SHOW TOPICS;为我提供了主题列表。我想通过创建一个流将所有这些主题信息存储在另一个主题中。我将轮询这个新主题(使用消费者)，每当在集群中创建新主题时，我的消费者都会收到一条消息。我想要一个KSQL查询来实现这一点。 提前谢谢。
浏览 13提问于2020-07-24得票数 0
回答已采纳
在配置ksqlDB时，我可以设置选项，它允许为ksqlDB的内部生产者进行压缩。因此，当我创建一个ksqlDB流时，它的输出主题将使用所选的压缩类型进行压缩。然而，据我所知，压缩性能受到生产者的批处理数量的严重影响。因此，我希望能够为ksqlDB的生产者配置和参数。有人知道是否以及如何为ksqlDB设置这些参数吗？
浏览 3提问于2021-11-09得票数 0
回答已采纳
在ksqlDB中存储什么样的数据？只有关于KStreams和KTables的元数据？我还假设ksqlDB实际上运行流处理器，所以它也是一个执行引擎。列表自动缩放吗？可以有多个ksqlDB服务器组件实例相互通信吗？它是专为需要大规模扩展的场景而设计的，还是只适合不喜欢编写J
浏览 4提问于2020-09-26得票数 1
回答已采纳
1回答
在KSQLdb中，我需要处理来自PostgreSQL的JSONB，但是我没有看到任何关于KSQLdb的JSONB的信息。我可以看到值格式字段为JSON，但是我们如何在其中访问JSONB。
浏览 7提问于2020-02-10得票数 0
1回答
我有一个关于以下数据流( ksqldb_topic_01 )的Kafka主题：{"city":"Sevilla","temperature":20,"sensorId":"sensor03"}{"city&
浏览 2提问于2020-01-24得票数 0
回答已采纳
1回答
运行命令：OpenJDK 64-Bit Server VM warning: Option UseConcMarkSweepGC was deprecated in version 9.0 and will likely be removed in a future release.
=========
浏览 5提问于2022-05-18得票数 0
2回答
我们没有在confluent-home/bin/windows目录中找到ksql-server-start.bat文件，但是我们在confluent-home/bin/目录下观察到一个同名文件，该文件不是批处理文件
浏览 52提问于2019-01-30得票数 2
回答已采纳
1回答
有人能为我解释一下如何在maven中访问多个存储库吗？我有一个在settings.yml中配置的公司镜像，它接受所有请求，问题是我需要一个不在镜像中的jar文件吗？<url>https://ksqldb-maven.s3.amazonaws.com/maven/</url> <mirror> <!<name>ksqlD
浏览 38提问于2020-09-02得票数 1
回答已采纳
我正在从https://ksqldb.io/quickstart.html#quickstart-content找到的docker-compor运行ksqldb-server 我的kafka bootstrap服务器在同一个VM上以标准的独立模式运行。我可以在一个主题中看到控制台消费者的消息： sudo kafka-avro-console-consumer --from-beginning --bootstrap-server localhost::
image: confluent
浏览 31提问于2021-07-16得票数 0
回答已采纳
我正在尝试用Java语言在我的KSQLDB应用程序中标准化反序列化，但是我正在努力理解如何处理由KSQLDB Client类型返回的Row类型。BatchedQueryResult query = ksqldbClient.executeQuery(queryString); // De
浏览 34提问于2020-12-10得票数 0
回答已采纳
1回答
我可以访问模式，它只是没有存储在Schema Registry中。现在，ksqlDB文档 --您必须有一个架构注册中心--才能处理Avro事件：
创建其他类型的定义，允许ksqlD
浏览 0提问于2020-05-05得票数 0
回答已采纳
我正试图在ksqldb之上构建一个应用程序。现在，通过这样的设置，我可以在所有可用的使用者上接收这些事件，但是我想在一个单独的用户上处理这个事件(处理过程会很长，所以我需要并行处理)。本地集群配置(它是Confluentic中的标准配置)：version: '2'
zookeeper: image: confluentinc/<e
浏览 14提问于2022-02-14得票数 0
回答已采纳
我想从KSQLDB中的表到elasticsearch中创建一个父-子关系。在elasticsearch映射中，我只定义了联接字段： "properties": {
"join_field": {对于ksqldb中的父级，我只需在ksqldb中的select中添加一个"joi
浏览 2提问于2022-09-08得票数 0
回答已采纳
1回答
我当前的ETL在batch process上运行，现在我希望它在流进程上运行，以便用于报告的数据始终是最新的。据我所知，我可以使用MongoDB连接器来捕获mongodb中的数据变化，然后将其发送到kafka主题。但在我的ETL中，我需要将处理后的数据存储到SQL数据库中。如何以及在哪里处理从mongodb发送到主题的数据，然后从该主题创建到另一个数据库的记录？我是否可以使用AWS lambda函数来执行处理和记录创建？但是，我如何在kafka中调用这
浏览 4提问于2020-06-17得票数 0
1回答
当我在我创建的流上使用ksqlDB中的DESCRIBE EXTENDED时，我得到了以下结果： Local runtime statistics:
consumer-messages-per-sec:last-failed: 2021-08-18T15:27:29.405Z 失败的消息(consumer-failed-messages: 1)是我故意发送给主题的消息，它失败了，因为我发送的数据类型与模式中定义的数据类型不同目标是构建一个对未能通过处理阶段的消息的监视器。 谢谢，露丝。
浏览 46提问于2021-08-18得票数 0
我有一个从MySQL用户表派生的主题，现在我想在ksqldb中创建一个表，该表始终包含过去50天内注册的所有用户。在文档中花了一些时间之后，我仍然找不到解决这个问题的方法。
浏览 1提问于2020-09-22得票数 0
1回答
我在GKE上运行了一个2节点的KSQLDB0.26集群。两者都可以独立运行，但它们并没有为高可用性而正确地设置，我也不知道为什么。主机扫描:没有选择ksqldb-2:8099，因为主机在1656932189568时未存活，主机不存在滞后信息。由于主机不存在滞后信息，所以没有选择ksqldb-1:8099。主机扫描:没有选择ksqldb-2:8099，因为主机在1656932189568时未存活，主机不存在滞后信息。由于主机不存在滞后信息，所以没有选择ksqldb
浏览 16提问于2022-07-04得票数 0
1回答
我试图在表和流之间执行连接，但由于某种原因，它无法工作。如果我碰巧在Postgres中输入了新数据，join语句将返回正确的值。
浏览 7提问于2020-07-14得票数 0
回答已采纳
1回答
我正在尝试让我的ksqldb服务器对接实例连接到远程Kafka集群，但是得到了一个错误。以下是细节--- ksqldb-server: context: ./Dockerfile container_name: ksqldb-server-remote - ":
浏览 20提问于2022-04-21得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
