在KafaStream中使用KTable join时，我可以分别为changelog topic和rocksDB设置保留时间，如下所示：当使用ksql(KTable-KTable)进行连接</em
浏览 2提问于2019-07-22得票数 0
回答已采纳
1回答
但是，我遇到了一个关于状态存储和更改主题保留策略的问题。用户会话可能在时间上无限期地发生，因此，我必须保证状态将在此期间持久存在，并在节点和集群范围内发生故障时恢复。(KAFKA-4015是在0.10.1版本中修正的，加窗口的变更主题在应用额外的保留时间参数时不会无限增长)。
“对于有窗口的KTables有一个本地保留<e
浏览 5提问于2020-03-04得票数 1
回答已采纳
1回答
我正在尝试设置kafka和ksql使用汇合平台，但ksql无法启动。_sudo systemctl status confluent*_
ksql failed t
浏览 0提问于2019-08-27得票数 0
回答已采纳
我们有一个卡夫卡制作者，它以非常高的频率产生关键信息，其保留时间= 10小时。这些消息是实时更新的，使用的键是值已更改的元素的ID。因此，该主题是一个变化的主题，将有许多重复的键。现在，我们试图实现的是，当一个Kafka用户启动时，不管最后一个已知状态是什么(新用户、崩溃、重新启动等等)，它将以某种方式构建一个包含主题中所有键的
浏览 0提问于2019-04-18得票数 4
3回答
假设相同的消息键有不同的值。xyz.com }
userid: 1,userid: 1,在上面的例子中，我只需要用户更新的最新值我的kafka流应该只给我第三个值，而不是前两个值。
浏览 1提问于2020-04-01得票数 3
2回答
如果删除A中元素与B中元素之间的连接，则必须保留以前存在的历史信息。如果连接状态发生变化，则必须保留关于旧状态的历史信息。A中没有连接到B的所有元素的列表(现在)。A中连接到至少一个具有特定状态的元素的元素的列表。曾经连接但不再是
浏览 3提问于2011-08-22得票数 0
回答已采纳
1回答
我使用的是Apache Kafka 2.12。1)当我在AWS胶水控制台中创建到Kafka的连接时，AWS胶水控制台上的‘测试连接’选项被禁用(灰显)。所以不确定我创建的连接是否正常。2)在我的设置中-输入源是Kafka / Topic，消息为JSON格式。目标I被保留
浏览 0提问于2020-06-04得票数 0
我有一个名为“stream_car_1”的KSQL数据流，它以lat-lon对的形式给出了它当前的位置。我有另一个KSQL数据流'stream_car_2‘，它以lat-lon对的形式给出了它当前的位置。我必须找到这两辆车之间的地理距离每一次实时的基础上。这可以通过KSQL实现吗？如果是，怎么做？
浏览 2提问于2020-03-24得票数 0
回答已采纳
1回答
我想加入两个流，我已将连接窗口设置为25小时，因为要加入的记录最多可相隔24小时。jobTransactionSerde,runsheetSerde))
org.apache.kafka.streams.errors.TopologyException:无效拓扑:连接窗口KSTREAM-JOINTHIS-0000000016-存储的保留期不能小于其窗口大小。
浏览 0提问于2018-12-31得票数 3
回答已采纳
1回答
我在GKE上运行了一个2节点的KSQLDB0.26集群。两者都可以独立运行，但它们并没有为高可用性而正确地设置，我也不知道为什么。当我试图从/clusterStatus端点获取内省集群状态时，hostAlive值始终是其中一个服务器的false。这是在运行SELECT * FROM X AS SELECT查询时发生的。\n状态:从DOMAIN_TIER_TABLE选择*；“statementText”：“选择*从DOMAIN
浏览 16提问于2022-07-04得票数 0
我正在与Kakfa合作，作为我正在创建的一个系统的骨干，数据可以大部分从数据库流到它，并且将数据的各个方面推入不同的主题，由定制的软件使用，或者使用Kafka Connect插件进入另一个系统。设置我发现的主要问题是<
浏览 17提问于2022-05-20得票数 0
我面临以下问题:改变一些与kafka相关的属性，并重新启动集群。
In kafka Consumer, there were 5 consumer jobs are running .如果我们做了一些重要的属性更改，并且在重新启动集群时，一些/所有现有的使用者作业都无法启动。
浏览 1提问于2017-06-22得票数 2
回答已采纳
1回答
这可能是一个简单的问题，但我无法在文档中显式地找到它:Flink的空闲状态保留是根据使用StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)时的事件时间计算的，还是总是基于处理时间计算的？我在计算每个会话的点击量
SELECT sessionId,
浏览 0提问于2020-09-30得票数 0
回答已采纳
主题正确地填充了JDBC源连接器的数据(仅值，没有键)。当我在KSQL中列出主题时，I可以使用无问题的访问ksql，而无需问题。当我选择推送流时，当我按下某个主题时(在我的例子中是用Kafka )，我可以得到消息。<code>H 210</code><code>H 111<//code>但是:当我调用“打印主题”时
浏览 5提问于2020-09-02得票数 1
回答已采纳
3回答
-休息起来了连接已启动ksql-server。ksql server启动
编辑
现在我正在使用./confluent start，然后在不同的linux终端窗口上使用kafka-server-start /path/to/server-1.properties和server
浏览 0提问于2018-10-02得票数 0
回答已采纳
1回答
我正在使用openfire和asmack lib。我正在实现安卓聊天应用程序中的online和脱机按钮，.How可以将我的存在设置为“不可用”。注意:我不想使用connection.disconnect()方法，因为**
此方法清除连接使用的所有资源。因此，不能简单地在此连接上调用connect()来重新使用名册、侦听器和其他有状态对象。这与意外断开连接(以及随
浏览 2提问于2013-07-30得票数 2
回答已采纳
我注意到，当使用Query Executed Successfully时，在每个查询选项卡的底部“状态栏”中都会显示执行时间和行数。但是，当标签空闲一段时间后，它将断开连接并丢失此类信息。我想解决一些复杂查询的执行时间问题，所以我不希望发生这种情况。我找不到任何设置来将这些信息保留在查询选项或选项中。
浏览 14提问于2019-01-03得票数 0
1回答
我正在尝试创建同时使用TCP和UDP的服务器和客户端。服务器在LAN设置中运行良好，但通过WAN传输时无法接收UDP消息。我认为这是因为用于发送数据的UDP套接字在NAT表中保留的时间不足以返回任何信息。是否有办法使UDP端口在路由器中保持打开状态(不转发端口)，或者使用与已连接的TCP连接相同的端口作为UDP端口？
浏览 3提问于2011-08-11得票数 3
回答已采纳
1回答
Kafka查询流
、、
我有一个业务需求，其中我需要有12小时的窗口，其中一个需要查询流数据。在12小时内，数据量约为1亿条记录。此外，我需要保持所有事件的顺序。使用Streams API，我构建了一个系统来实现这一点。真正的问题是，企业希望在事件和状态存储中进行搜索，几乎每个状态存储都是如此。搜索不是基于关键字的，而是基于值中的某些字段。我尝试了KSQL服务器，并尝试使用25M条记录的
浏览 0提问于2018-10-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
