1回答
我有一个包含多个日历的表，我需要获得表中每一行的前一个工作日。，但我无法获得每一项的正确返回。我最终将它分成了两个查询。Order By CALENDAR_ID asc, CALENDAR_DATE asc) FROM CALENDAR Where BUSINESS_DAY = 'Y'
当非工作日时，我不得不将其放入表函数中并交叉应用有没有更好的方法？
浏览 12提问于2020-02-14得票数 1
回答已采纳
假设有一个单独的Kafka主题，并且只有一个分区配置了无限保留策略。假设有两个消费者，Fast和Slow。这种设置，在同一分区中有两种不同的消费者速度，会对Kafka代理造成负面影响吗？从磁盘为Slow使用者
浏览 2提问于2019-12-02得票数 1
回答已采纳
2回答
我使用的是来自的消费者。kafka版本为0.10.1.0。，但运行几个小时后，一些分区(未收到任何新消息)的偏移量和滞后变得未知。如果有一条消息到达某个分区，而该分区的offset和lag未知，则offset和lag将重新可见，该消息将被消费。当有一些分区的当前偏移量和滞后未知时，我重新启动了消费者，此时，所有当前状态未知的当前偏移量和滞后的分区将重新从
浏览 0提问于2018-10-02得票数 2
以下哪一项是生产环境的最佳实践：2:创建多个流(每个流具有不同的app.id)，用于从不同的主题消费并写入不同的主题。我不确定第一种方法，因为当所有主题的数据量都会增加时，消费者就不会滞后吗？
更新1:我有两个话题。第一个主题有一个分区(因为我需要维护顺序)。
浏览 0提问于2018-10-29得票数 1
2回答
我们想知道对于给定的Kafka主题，还没有被Kafka Consumer消费和确认的消息数量。
有没有办法在Java中获得给定主题(主题有10个分区)中未消费的Kafka消息的计数?？
浏览 3提问于2019-10-24得票数 3
让我们考虑一个主题，其中包含多个分区和按事件时间顺序编写的消息，而没有任何特定的分区方案。每个任务可以以不同的速度处理传入的消息(例如，因为运行在具有不同性能特征的服务器上)。这意味着，在groupBy洗牌之后，当消息来自不同的任务时，在内部主题的同一分区中的消息之间的事件时间排序将不会被保留。当在aggreg
浏览 3提问于2020-11-16得票数 1
回答已采纳
1回答
我有一个设置，其中每个KafkaConsumers在一个主题上处理多个分区。它们被静态地分配分区，以确保每个使用者都有相同数量的分区要处理。还选择了记录键，以便在所有分区上具有相同的消息分布。在负载较重的时候，我们经常会看到少数分区会产生相当大的延迟(数千条消息/几分钟值)，而其他正在获得相同负载且被同一个使用者占用的分区则设法将延迟降低到几百条消息/几秒钟。构
浏览 5提问于2019-12-27得票数 5
2回答
基于动态偏移滞后函数的前馈非零值
、、、、
导出上述新列的逻辑是什么？
我需要得到每个人最近(以前)的部门；很容易使用滞后函数来获得最近(以前)的部门。实际上，我需要得到滞后函数将执行什么；但是滞后函数的偏移值必须是动态的，而不是静态值，例如1、2或3.；滞后函数需要在EmployeeName分区中迭代(向后)尽可能多的行，以捕获最近(先前)的非空部门值
浏览 21提问于2022-10-28得票数 0
回答已采纳
假设我有20个分区和5个工作人员。每个分区都分配了一个工作人员。然而，一名工人的运行速度比其他机器慢。它仍然在处理(也就是说，不是慢用户描述的)，而是其他机器的60%。这可能是因为工作人员运行在AWS EC2上较慢的VM上，磁盘或CPU坏了或什么的。是否以某种方式优雅地处理了重新平衡，以使缓慢的工作人员更少的分区？
浏览 2提问于2015-12-04得票数 6
回答已采纳
1回答
在卡夫卡，我们有一个领先的n个副本和其他复制来自生产者的数据和数据跨n复制被维护。
卡夫卡如何检查乌尔普斯呢?如果数据在卡夫卡消费者中不断地被推送，那么会不会总是在副本中出现滞后？
浏览 1提问于2021-11-02得票数 0
我有一个用例，在这个用例中，我有3个Kafka消费者在写一个主题，每个消费者中的消息需要按顺序处理。以防万一，如果其中一个消费者存在滞后，则需要更早处理的消息将被丢弃(写入条件)。那么，有没有办法可以维持这些消息的顺序呢？
浏览 2提问于2020-06-04得票数 0
1回答
我有一个kafka主题被划分成60个分区。生产者以默认的循环方式分发消息。到目前一切尚好。但在消费方面，滞后正在加剧。没什么好奇怪的。令我惊讶的是，这种滞后有时是如何分布的：
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAGkafka-python-2.0.2-b9111d9a-940f-4f3c-9087-6b739abf06b4 /88.88.54.169 kaf
浏览 10提问于2022-09-27得票数 0
到目前为止，我有一个有10个分区的Kafka主题。我们有10000名客户，他们不断地将不受控制的数据倾倒到流中。目前的问题是问题：我已经通过了：；但是考虑到客户
浏览 1提问于2022-06-30得票数 0
我们是卡夫卡的制作者，为一个只有一群消费者消费的主题制作信息。消费者的速度有很大的不同。我们总是有一定数量的消费者滞后作为缓冲。生产者是否有可能知道使用者组的每个分区的滞后，并首先以最低的延迟向分区生成消息？如果我使用C/C++客户端或Java客户端，是否有可能？
谢谢。
浏览 4提问于2020-01-13得票数 0
回答已采纳
我正在尝试熟悉MySQL集群社区服务器(版本:5.6.27-NDB-7.4.8GPL)，我有第一个令我困惑的问题。我搜索了文件和论坛，但没有找到相关的东西。我在集群上有一个非常简单的表，其中有4个数据节点/分区： id int(10) NOT NULL ,
surname varchar(/女性的价值观)。但是，如果我将性别定义为nvarchar(6)或varchar(40)，那么行就会像我期望的那样
浏览 0提问于2016-01-03得票数 2
回答已采纳
3回答
我有这样的数据。1 0 problem.id.problem.4 ")565662 PRABNBWG 1 0 problem.id.problem.5 NA
"
浏览 6提问于2020-06-02得票数 0
回答已采纳
我有一个函数，输出两个字符串的不同单词。这很好，直到我想迭代两个数组，其中包含字符串，并输出第三个数组，显示“额外”的单词，如果有任何。代码如下：设实= {{query29.data.produkte}}var检验
浏览 10提问于2022-07-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
