回答情况：
提问时间：
问题标签：
KTable<key, Value1> table1我试图通过键连接两个KTables (无窗口)，并将结果作为<Key,value1,value2
浏览 0修改于2018-06-17得票数 3
汇合网站的提到了以下几点：
左KTable可以有多个记录，这些记录映射到右侧KTable上的相同键。如果右KTable中存在相应的键，则对单个左KTable条目的更新可能会导致单个输出事件。因此，对右侧条目的单个更新将导致对具有相同外键的左KTable中的每条记录进行更新。
浏览 8提问于2020-12-01得票数 3
回答已采纳
从来没有调用过LogAndContinueExceptionHandler，并且consumePojo状态从PENDING_ERROR到错误的转换@Bean }
为什么在KTable的情况下不调用LogAndContinueExceptionHandler？注意:如果代码被更改为KStreams，那么我会看到日志记录和记录被跳过，但是KTable没有!！
浏览 18修改于2022-11-08得票数 0
我在我的应用程序中实现了一个KTable和一个KStream连接，并在以下情况下期望输出消息；我已经观察到我的应用程序可以像预期的那样执行1和2，而不是3。
浏览 3提问于2021-02-10得票数 0
1回答
我有一个卡夫卡流应用程序，利用KTable。我的应用程序运行了一段时间，所以KTable已经建立起来了。
如何截断KTable (假设我的应用程序能够处理表的重构)？
浏览 1提问于2018-10-09得票数 1
回答已采纳
1回答
我想使用Kafka stream来处理这个话题，并根据一些条件更新KTable。每条记录都无法更新KTable。因此，我需要处理多个记录，以了解是否需要更新KTable。如果该用户至少有一个会话If仅具有已连接的事件，则必须将KTable更新为用户在线(如果尚未更新)。如果用户的所有sessionId都有Disconnected事件，则必须将KTable更新为用户脱机(如果尚未更新)。
我该如何实现这样的逻辑呢？我们是否可以在所有应用程序实例中实现此KTable，以便每个实例都可以在本地
浏览 0提问于2020-06-17得票数 0
, MyObject> process(KStream<Object, IncomingObject> input) {return table.toStream();我试图将KStream转换为KTable，然后再转换为KStream，但是无法从KStream转换为KTable
价值是json。
浏览 0修改于2020-10-16得票数 0
此操作失败，引发以下错误：处理器KTABLE连接-输出-0000000018不能访问StateStore KTABLE连接输出状态存储-0000000019，因为存储没有连接到处理器.94ec-adad071b4d24-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: failed t
浏览 1修改于2020-02-11得票数 1
我想了解KTable和KsqlDb之间的区别。我需要来自我的“状态”主题的两个数据流：
我可以创建紧凑的主题，并使用KTable作为键值存储，并更新1种情况。此外，我还将使用使用者订阅第二种情况下的状态事件。在这些情况下可以使用KSqlDb吗？
浏览 5修改于2022-08-10得票数 0
到目前为止，我要创建KTable，但是当我迭代它时，控件会跳过它。谢谢。payloadJson.toString(); final KTable<String, String> kTable = builder.table("testktable");
kTable.toSt
浏览 2修改于2021-07-23得票数 0
1回答
下面是我构建的一个示例KTable，它是一个简单的聚合： String name = stream .aggregate( .queryableStoreName(); 我需要做的是将最终的KTable(在应用过滤之后)存储在状态存储中，而不是初始的KTable中。目前，KTable.queryableStoreName()返回null。我目前的解决方案是应用
浏览 19提问于2019-05-31得票数 1
回答已采纳
1回答
试图通过KTable从“连接-信任”主题中获取记录 StreamsBuilder builder = new StreamsBuilder(); Kafka
浏览 0修改于2018-04-19得票数 3
回答已采纳
这两个主题的密钥都不是设定好的，所以我必须使用还原剂将KStream(主题B)转换为KTable。这是我的代码： .stream("TopicB", Consumed.withTimestampExtractor, new ValueJoiner({...})) .to("result")
1) KTable初始化速度
浏览 3修改于2020-05-01得票数 0
假设我将A-Event KStream聚合为A-Snapshot KTable，将B-Event KStream聚合为B-Snapshot KTable。此时，我们可以假设我们有一个持久化的kafka主题和一个rocksDB本地存储库，用于A-KTable和B-KTable聚合。然后，我的拓扑将与A-KTable一起使用B-KTable来生成一个连接的AB-KStream。尽管如此，我的问题是A-KTable和B-KTable物化生命周期(即chang
浏览 1提问于2019-05-21得票数 0
回答已采纳
Location(lat, lon); });locations.to(Serdes.String(), new LocationSerde(), "location_topic_aux");
KTable</e
浏览 0修改于2017-03-22得票数 38
回答已采纳
对于以下拓扑的行为，我有一些问题： // join the event with the according entry in the KTabletopic
state Y written to the KTable
浏览 0修改于2017-09-15得票数 5
回答已采纳
<K>, Long> table2 = stream2.groupByKey().count(timeWindow, "Stream_2_Count_Store");
KTable<Windowed聚合到最终的KTable，聚合对象是从T到步骤1中的两
浏览 3修改于2021-05-31得票数 8
回答已采纳
在这里，我使用了KTable-KTabke连接，因为它们的密钥相同。<String, POrder>table("orders"); // Static KTable
浏览 0修改于2020-06-22得票数 2
在KafaStream中使用KTable join时，我可以分别为changelog topic和rocksDB设置保留时间，如下所示：当使用ksql(KTable-KTable例如：left join conversions on clicks-
浏览 2修改于2020-05-14得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号