我创建了一个这样的流： CREATE STREAM TEST1 WITH (KAFKA_TOPIC='TEST_1',VALUE_FORMAT='AVRO'); 然后，我通过CLI像这样查询流： SELECTFROM TEST1; 结果如下所示： 1571225518167 | \u0000\u0000\u0000\u0000\u0001\u0006key | 7 | 7 | blue 我想知道为什么密钥的格式是这样的我的查询是不是有误？值应如下所
浏览 11提问于2019-10-16得票数 0
回答已采纳
1回答
我正在编写这个卡夫卡流应用程序，它接收被注册在卡夫卡主题中的传感器读数(在JSON中作为消息)，并在每分钟、每小时和每天的基础上对这些读数的值执行一些聚合。然后，我将从这些聚合中派生的KTables具体化，并使用默认状态存储存储它们。我想知道是否可以使用KSQL查询这些表。
浏览 1提问于2019-10-01得票数 1
回答已采纳
卡夫卡名称：test{"a":1，“b”：“a”{a“a”：2，"b":"b"}用(kafka_ test_stream123 =‘test’，key=但, *select *从test_table发出更改；*
当我按下Ctrl键时，它会发出以下信息：
+--------+-----------+-----------+ _ROWT
浏览 2提问于2020-05-02得票数 0
回答已采纳
1回答
我在主题之外创建了一个流，并重新设置了它的键值，因为键为空。 在这个新主题的基础上，我创建了一个表。我们的目标是拥有一个不断更新的对象表(这里是类别)。当然，我再次执行了select操作，因为我知道当我们仍在运行查询时，'update‘行就会出现。character varying(15) NOT NULL,); KSQL中的categories表： ks
浏览 26提问于2019-09-12得票数 1
回答已采纳
如果你粘贴一个对象，里面有一千个键/值对，并且控制台记录了这个对象，Chrome Dev工具将会记录前几个键/值paris，然后是...，然后是其余的键/值对。我如何看到所有的键值对呢？
浏览 14提问于2016-07-28得票数 0
回答已采纳
3回答
我已经研究了Interactive queries和KSQL，但我似乎无法确定是否可以基于键查询特定的记录。假设我在一个主题中有一条记录，如下所示： { value: id: "1", }
} 可以在主题中搜索关键字另外，KSQL和交互式查询会占用整个主题来执行查询吗？
浏览 30提问于2020-01-02得票数 0
回答已采纳
我从一个JSON值格式的主题中创建了一个KTable，主题的生产者还为Kafka级别的每个消息包含了一个键，JSON消息本身包含一个名为key的JSON属性，我在下面的语句中将其用作ROWKEY： createvarchar) with (KAFKA_TOPIC='INCOMING_SUBSCRIPTIONS', VALUE_FORMAT='JSON', KEY='key'); 有没有一种方法可以使用主题中的消息中的键<
浏览 23提问于2019-01-29得票数 2
1回答
我在阿波罗缓存方面有一些问题，我会描述这个场景:我有一个查询，QueryOne返回一个键名为"getUserData“的数据，另一个查询返回不同的数据，同样的键名为"getUserData"，两个响应可能有相同的键这种行为会导致我的缓存被覆盖，据我所见，阿波罗每次查询都保存键值而不是键值。我需要阿波罗缓存来分离这两个缓存对象，并理解它
浏览 3提问于2022-11-02得票数 0
3回答
具有通用应用程序日志(log4j)的第一个主题。存储诸如HTTP请求/响应和警告、异常等.可以有多个日志与一个逻辑业务请求相关联。(这些日志在几秒钟内就会发生)
因此，单个逻辑业务请求可以有多个日志、命令和事件，这些日志、命令和事件由微服务相互传递
浏览 0提问于2018-03-11得票数 6
1回答
我正在使用CDC和Debezium连接器将中的几个表流到Kafka。其中一个SQL表在KSQL中表示为流，其余的是我希望加入到流中以丰富数据的KSQL表，因此我有一个KSQL流链，每个表都将一个新的KSQL表连接到该链中前一个KSQL流的输出。让A是一个KSQL流。
设B到D是KSQL表。很好，但是A‘给了我一个错误：Source table (
浏览 0提问于2019-08-09得票数 0
我已经在RDBMS世界工作了很多年，但我希望探索整个nosql运动。所以这是我的第一个问题：
有可能出现重复的密钥是不是很糟糕的做法？例如，根据姓氏键入的地址簿(很可能是搜索项？)可以有多个实体。那么使用姓氏是不是不好的做法呢？关键字应该是实体的最“可搜索”的定义吗？在这个全新的世界里(对我来说)，有没有什么“最佳实践”的资源？我对东京内阁(特别是tc接口)很感兴趣，但不知道如何遍历具有相同密钥的不
浏览 0提问于2010-01-15得票数 1
回答已采纳
我从table在ksql中创建了一个kafka topic。将一组数据推送到主题和表中。发布了一个查询并得到了响应。这是我第二次将相同的数据推到topic中，table再次加载。现在，当我查询时，响应是2行，而不是带有2种不同ROWTIME时间戳的1行。
我认为，如果相同的ksql table进入并保留最新值，则key应该覆盖该值。但这是不可能的。我的理解正确吗？如何使table保留最新值并在相同键
浏览 1提问于2019-04-05得票数 2
回答已采纳
我确实配置了到数据库的连接，并在主题上配置了所有数据传输，因为当我运行使用者时，它会返回数据。非常感谢
浏览 0提问于2018-10-11得票数 0
OpenJDK 64位服务器VM警告:选项UseConcMarkSweepGC在>版本9.0中被废弃，很可能在以后的版本中被删除。在docker日志imageid日志文件中完全没有显示错误。我从头到尾，甚至在尝试查询时，都没有说过“我无法连接或加入集群”，甚至“我试图加入集群”之类的内容。在所有三台服务器上尝试相同的查询时，都会出现错误。前两个服务器运行完美，如下所示，但是不同机器上的容器得到“无法执行拉<em
浏览 12提问于2020-06-22得票数 0
回答已采纳
1回答
我有一个解析查询，它将返回许多具有不同键和值的对象。我想限制特定键返回的相同值的数量。
假设我正在查询一个藏书的图书馆。假设我正在获取book和author对象键。有没有办法限制相同的键值？例如，如果我有10本分别由海明威、吐温和狄更斯写的书，我是否可以将查询限制为只返回他们前5本书中的每一本？
浏览 2提问于2015-07-19得票数 0
1回答
我使用的是合流3.3.0。我使用jdbc-source-connector将消息插入到我的Oracle表中的Kafka中。这个很好用。我桌子的id应该成为相应的卡夫卡信息的key。我的主键(id)将保持不变作为引用。
每次更新行时，时间戳字段都会被
浏览 1提问于2018-08-01得票数 0
是否有可能在Kafka中创建一个日志压缩主题，其中通过压缩保留最旧的值(而不是新值)，用于分析目的？我有一个查询要创建，比如我正在寻找使用ksql / ksqldb /kstream的方法。我想到的最简单、最有效的方法是创建一个日志压缩的主题或ktable，它保留每个键的最早的值。
我想知道压缩是否有可能保留最
浏览 10提问于2020-05-11得票数 0
1回答
Linq 2 SQL:复合主键
、、、、
我有一个有两个外键的连接表。它们是表的主键。我试图在Linq中绘制这幅图：public class PartToPart [Column(Name = "PartID", IsPrimaryKey如果我尝试将新条目保存到此表中，则会得到一个违反约束的错误：
违反主键约束..。无法在对象dbo.PartToPart中插入重复密钥。重复的键值是..。我尝试通过I
浏览 2提问于2015-03-15得票数 4
回答已采纳
key.separator=:" \ --from-beginning创建以下流和表并运行联接查询。KSQL： CREATE STREAM SAMPLE_STREAM
(DEAL_ID VARCHAR, DEA
浏览 0提问于2018-04-30得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
