1回答
我正在尝试在ksqlDB中创建一个流，以便从kafka主题中获取数据并对其执行查询。(KAFKA_TOPIC='public.location', PARTITIONS=10); 主题public.location中的数据是ConnectorName":null,"DbName":null,"DbSchema":
浏览 14提问于2021-07-28得票数 2
回答已采纳
我目前正在使用 (见下文)在ksqlDB中生成一个自动递增的列。但是现在我想知道这种方法是否存在竞争条件或其他同步问题。这是在ksqlDB中生成自动递增列的好方法吗？如果没有，还有更好的办法吗？假设您希望将一个ksqlDB流中的值插入另一个流中，同时在目标流中自动递增一些整数值。=1)；用(k
浏览 3提问于2020-06-17得票数 0
回答已采纳
在配置ksqlDB时，我可以设置选项，它允许为ksqlDB的内部生产者进行压缩。因此，当我创建一个ksqlDB流时，它的输出主题将使用所选的压缩类型进行压缩。然而，据我所知，压缩性能受到生产者的批处理数量的严重影响。因此，我希望能够为ksqlDB的生产者配置和参数。有人知道是否以及如何为ksqlDB设置这些参数吗？
浏览 3提问于2021-11-09得票数 0
回答已采纳
在这个集群中，我希望将自管理的ksqlDB连接到聚合云控制中心。下面是我从合流云复制的配置，并将其放入托管的ksqldb。这个自管理的ksqldb是一个单机GCP计算单元。下面的属性中也存在相同的配置。/ksql-server.properties &/home/confluent/confluent-5.5.1/bin&#
浏览 0提问于2020-09-07得票数 0
我试图通过KSQLDB获取消息的最新值。因此，我使用LATEST_BY_OFFSET。在文件中，说明如下：EARLIEST_BY_OFFSET(col1、earliestN、ignoreNulls)
流将指定列的最早N个值作为数组返回。分区中最早的值具有最低的偏移量。可选的ignoreNulls参数控制是否忽略空。默认情况是忽略空<
浏览 2提问于2020-12-03得票数 0
回答已采纳
1回答
我试图加入来自两个不同的卡夫卡主题的消息，这些主题与ksqlDB有不同的分区号。当我从每个主题创建流并试图加入它们时，ksqlDB不允许bec。基主题中的不同分区号。当我对每个主题执行以下步骤时:根主题中的->create流，带有一个分区的新主题的第一个流中的->create流(减4到1)，在具有一
浏览 4提问于2022-10-18得票数 0
我一直在摆弄ksqlDB，它真的很整洁。将数据输入Kafka，创建流甚至表，效果很好。现在，我想将可视化层/ BI工具连接到表中的数据，以创建仪表板或交互式BI报告(例如，Superset、Redash等)。是否有一种方法可以将JDBC客户端直接连接到ksqlDB / Kafka流，以便它可以查询ksqlDB中的表？说我应该使用REST将应用程序与结果连接起来，
浏览 5提问于2020-03-08得票数 0
回答已采纳
1回答
----------------我是从一个主题private-import-clients编写KSQL的，我假设创建的流的结果会给出一个主题、、CLIENT_STREAM、或其他名称。这是正确的吗？如果是这样的话，KSQL在哪里存储这个主题CLIENT_STREAM？我有一个Spring应用程序，它将使用主题CLIENT_STREAM。
浏览 5提问于2022-05-18得票数 0
2回答
我没有看到任何关于asp.net core的KSQL DB的文章/博客，也没有什么可用的文档。如果你能帮助我在kSQLDB和asp.net core上的代码/文章/博客，我将不胜感激
浏览 4提问于2021-07-13得票数 2
在ksqlDB中存储什么样的数据？只有关于KStreams和KTables的元数据？我还假设ksqlDB实际上运行流处理器，所以它也是一个执行引擎。列表自动缩放吗？可以有多个
浏览 4提问于2020-09-26得票数 1
回答已采纳
1回答
我有一个关于以下数据流( ksqldb_topic_01 )的Kafka主题：{"city":"Sevilla","temperature":20,"sensorId":"sensor03"}
% Reached end of topic ksqldb_topic_01 [0] at offs
浏览 2提问于2020-01-24得票数 0
回答已采纳
我正在使用Confluent的KSQLDB在KAFKA中创建一个表。我已经很容易地使用汇合式提供的UX，但是我正在尝试自动化这个过程，因此我需要一个命令行启动能力来执行这个任务。我已经能够使用Confluent的KSQLDB接口来执行简单命令(“列表流”)的curl，但是更复杂的语句，比如创建一个表，似乎是不可用的，或者没有可以克隆/使用的</e
浏览 4提问于2021-02-23得票数 2
回答已采纳
我的数据(流)：24 | CIRCUS | John Doe | an=‘马戏团’组按ROWKEY；
下面的UPDATE Matthias答案正确地解释了表和接收器主题显示了更改事件，因此看到中间值</
浏览 5提问于2020-05-25得票数 2
回答已采纳
我用VALUE_FORMAT='JSON' TOPIC='MYTOPIC'在KSQLDB中创建了一些虚拟数据作为流 设置已经结束了Docker-compose。我正在运行Kafka代理、Schema-registry、ksqldbcli、ksqldb-server、zookeeper 现在，我想使用该主题中的这些记录。我也在Java Spring中尝试过不同的用例，但都没有成功
浏览 20提问于2021-04-23得票数 0
回答已采纳
所需的功能:对于给定的键key123，多个服务并行运行，并将其结果报告到单个位置，一旦为key123收集了所有结果，这些结果就会传递给新的下游使用者。最初的想法:使用亚马逊网络服务的DynamoDB来保存给定条目的所有结果。每次准备好结果时，微服务都会对key123上的数据库执行修补操作。输出流检查每个更新以查看条目是否完整，如果是，则将其转发到下游。
新想法:使用Kafka Streams和KSQL来达到相同的目标。所有服务都将它们
浏览 9提问于2019-07-12得票数 0
我运行这个查询USER_EVENTS是一条流。在此之前，我将auto.offset.reset设置为earliest。此查询运行缓慢。我也不知道原因。然后进行查询，检查以上查询的用户id，并在kafka connect中进行搜索。我发现查询需要获取主题中的所有消息，尽管我只需要一行。是真的吗?为什么要把所有的东西都取出来呢？我认为获取一个就足够了，因为我必须添加limit 1来查询。USER_EVENTS背后的</em
浏览 4提问于2022-10-25得票数 0
回答已采纳
本主题中的数据使用模式注册表使用avro序列化。模式主题名称与主题名称相同-“some”，没有“-value”后缀我试图评估这是否可以使用ksqldb完成，并有两个问题：
是否可以基于现有主题并使用现有模式创建流/表？因此，新表的字段将从现有模式automaticallycould中提取，在
浏览 0提问于2020-05-14得票数 0
我正在使用kSQLDB并从一个主题创建一个流，当我显式声明一个KEY时，我会得到一个不属于我的键的随机值。如果删除KEY关键字，我需要的值实际上是在Id列中指定的。# key{ "other": &
浏览 3提问于2021-10-20得票数 0
我看过并尝试过很多使用avro的ksql stream的例子，但它似乎不支持TopicRecordNameStrategy。是否可以使用主题策略名称TopicRecordNameStrategy为主题创建流？
浏览 0提问于2020-09-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
