1回答
在streams应用程序中，我将每个键为A的记录平面映射到键为U、V或W的记录，将每个键为B的记录映射为键为X、Y或Z的记录。我想为这些平面映射记录创建一个KTable。但是，我希望此KTable的键与最后一次平面映射操作为键A和键B的每个记录生成的键匹配。例如，如果在某个特定时刻，KTable具有键X、Y和U，然后发布了一个键为B的记录，并将其
浏览 13提问于2020-06-04得票数 1
回答已采纳
我有一个KTable，其数据看起来如下(键=>值)，其中键是客户ID，值是包含一些客户数据的小JSON对象：4 => { "name" : "Jerry", "a
浏览 0提问于2017-03-09得票数 10
回答已采纳
1回答
在包含tombstone值的ktable上执行groupby时会发生什么？看起来groupby没有被评估，但是tombstone会像filter方法一样被转发吗？
浏览 0提问于2019-09-11得票数 0
如果收到另一个keyB/value123 123消息，并且value123是相同的，但以前有一个不同的键(keyD)，我需要删除旧的keyD/value123 123。我没有收到关于旧钥匙的“墓碑”信息--因此我不得不暗示墓碑，因为一个新的钥匙刚到了这个主题上，有着同样的价值。如果键/值位于另一个应用程序实例的状态存储区，则无法访问(删除)键/值，因为每个实例的状态都是本地的。我需要驱逐旧数据。我怎样才能做到这一点？从另一个角度来看：
如果带有<e
浏览 2提问于2020-08-19得票数 1
回答已采纳
1回答
<K>, Long> table2 = stream2.groupByKey().count(timeWindow, "Stream_2_Count_Store");
问题是:连接和聚合操作的状态存储没有保留机制，并导致磁盘(RocksD
浏览 3提问于2017-11-22得票数 8
回答已采纳
1回答
KSQL选择删除事件
、、、
我有一个kafka KTable，其中包含用户Ids。我把这个Ktable叫做"UserWhitelist“。这个Ktable是由主题"Users“构成的。如果在用户主题中插入/更新了新消息，我将在Ktable中获得新记录，并引发事件。如果我发送一个带有墓碑的密钥到用户主题，Ktable中的记录会被删除，但我的consumer..below中没有任何事件是代码，我如何监
浏览 10提问于2019-09-24得票数 0
我们正在尝试实现下面描述的用例，我们有我们希望克服的实现问题，我们正在尝试通过匹配两个流的消息中存在的关键字(JSON)来在两个Kafka主题之间进行KStream连接。此外，我们应该维护消息序列，因为它是从源文件到达KStream的。
场景是，如果匹配的键还没有到达任何一个流，我们应该停止或重试join，直到预期的键到达其他主题。问题1:如何在其他主题中停止或保持join，直到预期的键到达。例如，KTable有密钥100，但KStream还没有收到密钥100，那么我们应该重试
浏览 2提问于2019-05-08得票数 2
我有一个主题，在这个主题中，我从各种设备上获得了一系列事件。有n个设备每秒发出一次天气报告。对于设备1：- t1，t1(在同一时刻，然后间隔s秒) t2，t2(然后间隔s秒)，t3，t3
然而，我想在kafka中删除这些作为突发事件出现的重复记录我试图使用Kafka stream API提供的窗口和ktable的概念，但这似乎不太可能。有什么想法吗？
浏览 2提问于2018-07-07得票数 0
在实时运行中，为收到的每条消息发送一条消息。如果我发送带有"key1“、"key2”和"key1“键的消息，则会得到以下输出。(key, value) -> KeyValue.pair(key, value), Serialized.with(Serdes.String(), Serdes.String()));
KTable
浏览 1提问于2018-10-19得票数 2
回答已采纳
在我们的应用程序中，有接收无序事件的可能性，所以我喜欢根据有效载荷内的业务日期来排序事件，而不是按它们放在主题中的时间来排序。为此，我编写了一个自定义TimestampExtractor，以便能够从有效载荷中提取时间戳。直到我在这里告诉您的所有内容都非常有效，但是当我针对这个主题构建KTable时，我发现我接收到的事件(从业务角度来看，它不是最后一个事件，而是在最后接收到的事件)显示为对象的最后一个状态，而ConsumerRecord然后，在调试过程中，我看到如果TimestampExtractor返回-1作为结果，卡夫卡
浏览 0提问于2018-10-05得票数 1
回答已采纳
1回答
如我所想，KTable -带有compaction删除策略的简单kafka主题。此外，如果为KTable启用了日志记录，则还会有changelog，然后，删除策略为compaction,delete。KStream<K, V> source = builder.stream(topic1);
KTable<K, V> table = builder.table(topic2); // what/
浏览 2提问于2018-09-25得票数 19
回答已采纳
问题:如何将从TOPIC_2创建的流(step2格式)连接到KTable stateTable( step1格式)。目标:在join操作之后，如果我们改变AlarmState( KTable stateTable的值)对象的状态，相同的状态应该反映在stateTable(step1的一部分)中 在Step1(从TOPIC_1创建)中描述了KTable(作为stateTable)，在另一个主题TOPIC_2中，生成了数据(在step2中
浏览 17提问于2019-04-17得票数 0
我的主题有一个保留策略(以字节为单位)来老化旧记录。
我担心将所有的记录转储到KTable中，让StateStore无限增长。
浏览 4提问于2018-01-03得票数 7
回答已采纳
1回答
如何识别主题的KTable物化何时完成？
例如，假设KTable有几百万行。而且，一旦调用了上面的"to“方法，是否可以在下一个计划中调用它，或者第一个调用是否总是处于活动状态？因此，除非压缩过程试图清理这些项并只保留最新的项，否则下游应用程序将使用来自主题的相同密钥查询的所有可用条目，从而导致重复。我假设KTable将只有RocksDB中给定密钥的一条记录。如果我们有一种方法来安排物化，这将有助于避免重复。另外，减少主题中持久化的数据量(增
浏览 1提问于2018-05-21得票数 2
回答已采纳
2回答
我有需要与ktable / changelog主题匹配的事件流，但是匹配是通过ktable条目的属性上的模式匹配完成的。所以我不能根据键加入流，因为我还不知道哪一个是匹配的。示例：{ [efg]: {id: 'efg', prop: 'another pattern'}A流：
{ id: 'xyz', match:
浏览 4提问于2020-02-04得票数 4
1回答
背景给出的示例是一个订单服务，它需要等待三个单独的验证服务(所有这些服务都是通过相同的主题发送)才能返回一个PASS。(我的解释是，在同一主题上将有三条具有相同密钥的验证消息，每条消息都有一个值表示成功或失败。)
上述每一步到底是如何工作的，涉及哪些类/方法？
如果是这样的话，输出将是一个，步骤二可能使用一个方法并返回一个。但是
浏览 2提问于2020-07-30得票数 1
我有一个输入流，我用它来创建一个ktable。然后，我使用toStream()方法使用ktable changelog创建一个输出流。,
KStream<String, event> outputStream = KTable.toStream(); 对于inputStream中的每条消息，我希望在outputStream中获得一条消息。对于大多数消息，它工作得很好，但在特定情况下，我会丢失一些事件:如果我在很短的时间间隔(不到5秒)内收到2条具有相同
浏览 24提问于2021-06-23得票数 1
回答已采纳
4回答
最近，苹果根据这一规定，中间证书于2月14日到期，必须手动下载，并应取代系统密钥链中较旧的过期证书。
浏览 15提问于2016-02-19得票数 3
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号