最少消耗n条记录，最多消耗n条记录，但等待m秒后返回记录

文章/答案/技术大牛

发布

1回答

apache-kafka、kafka-consumer-api、spring-kafka

我有一个用例，消费者必须消费最少的n条记录才能开始下一步的处理，但在等待m秒后，必须返回p条记录，其中p< n。在kafka中有实现这一点的方法吗？我可以配置最小获取大小和最大轮询记录来控制记录的数量，但不确定如何实现问题的第二部分。

浏览 13提问于2019-05-12得票数 0

回答已采纳

2回答

Kafka消费者偏移量提交后消息先消费

apache-kafka、kafka-consumer-api

system which can take random time for different requests or timeout in 5 seconds.我遇到的问题是，如果产生了较晚的记录，但前一条记录仍未超时，则如何提交或提交哪个偏移量。假设我在一批中获得了2条记录，第一条消息的外部调用仍在等待，而第二次调用已完成。如果我等待5秒等待外部响应，Kafka消息的消耗

浏览 2提问于2018-01-05得票数 2

1回答

替换一百万条记录的列值(xml记录)

sql、sql-server、tsql

我有一个'Customer‘表，表中有大约120万条记录，其中一个列'customer_records’的类型为ntext，其中包含xml数据。我需要替换列中所有现有记录中的url值。我尝试使用下面的replace查询，但执行查询需要大约20分钟的时间。Update CustomerN'http:/&#x

浏览 18提问于2021-09-16得票数 0

2回答

log4net -是否有过滤器只记录第N条消息？

.net、log4net

目前，它每{n}秒更新一次，并将带有该值的调试消息记录到ILog的实例中。有没有人知道这样做的任何方法，而不涉及我自己的ILog实现？

浏览 0提问于2009-07-30得票数 9

回答已采纳

2回答

Oracle sql在执行完成操作时不会从temp释放空间

oracle、sorting、null、temporary

有一个表(假设是TKubra)，其中有2.255.478条记录。有一个类似这样的查询： from kubra.tkubra order by c1kubra asc;ckubra有索引，但当语句执行时，它会执行全表扫描，其成本是258.794。和往常一样，结果返回null。当语句执行时，它将消耗临时表空间，

浏览 5提问于2018-06-11得票数 1

1回答

如何使用KafkaConsumer实现poll()？

python、apache-kafka、kafka-consumer-api

我正在运行一个守护进程，每隔5秒将500条记录推送到Kafka中。我正在使用KafkaConsumer从卡夫卡中拉取记录。我用Python3编写了一个消费者代码，只提取100条记录，消费者不会等待超过8秒。在本例中，我使用的是poll()方法。但下面的代码不是返回100条记录，而是从Kafka返回新添加的500条记录。enab

浏览 161提问于2021-10-11得票数 0

2回答

获取算法在特定时间跨度内可以处理的最大数据

algorithm、measurement

我可以创建一个数组(或多个数组)，并用随机数填充它们，但是要确定在一分钟的运行时间内会有多少个数组结束，这将是一项非常漫长的任务，因为您总是需要等待。我可以做些什么来有效地找出这方面的信息？

浏览 0提问于2016-10-28得票数 0

1回答

(因为Histogram_read_id是引用Histogram_read表记录的一个键)，但是由于它是一对多的关系，所以可以进行内部连接吗？而且，因为我只想要直方图表中的所有记录和列--只是添加了字段，所以如果我在加入Histogram_read表和Histogram_read表之前加入了直方图表，那么如何确保直方图的最终表不会被Histogram_read我有以下查询，但不起作用：as select M.parameter, Nest.* from memory_map M

浏览 0提问于2021-05-27得票数 0

2回答

Rivr VoiceXML for Java中的“稍等一下”消息

java、voicexml、rivr

我需要这样做，因为我必须在返回用户之前执行一些耗时的任务。应用程序流是： 1)播放欢迎消息( TTS ) 2)从用户收集语音(Rivr语音记录交互) 3)播放“等待第二”TTS消息作为语音和相关业务流程的处理耗时(耗时数秒) 4)时间消耗任务5)播放(TTS)一切正常，但是“等待一秒钟”消息就在耗时的任务和进程的综合结果之后播放(我的意思是，用户说话，必须等待)，尽管在我的对话框代码中，它放在“耗时任务”之前。由于某种原因，Rivr或VoiceXML引擎正在缓冲这两<e

浏览 7提问于2015-09-19得票数 1

回答已采纳

2回答

用于油层采样的Knuth伪代码中可能存在的错误

algorithm、random、combinations

下面是Knuth中用于水库采样的伪代码(如何从一组n数中选择k数，确保每个数具有相同的概率)。 M = random(1, i); SWAP theMth value and ith valueend for 从这段代码中，M < K的概率是

浏览 2提问于2013-07-14得票数 0

4回答

Apache Kafka交付订单

apache-kafka、kafka-consumer-api

我的消费者首先将消息M1写入Kafka上的主题T1 (通过同步api)，然后将消息M2写入主题T2。此时，消费者正在收听主题T1和T2。是否可以保证每当消费者看到主题M2上的消息T2时，都会看到主题T1上的消息M1？(因为在M2之前编写了M1 )

浏览 2提问于2017-01-16得票数 1

2回答

担心perl IO::Socket丢失UDP数据包

perl、sockets、udp

它工作得非常好，但我担心它可能会丢失syslog事件，所以对它进行了测试基本上，我推入了100条"this is a test perl“消息，有时会传出100条--但一旦传出99条消息(通过运行$NUM这是在我们的生产系统上，它每秒处理500-1500条syslog消息。像往常一样，只有在有测试流量的情况下，它才能完美地工作，但在负载下我不确定。tcpdump显示通过eth0传入的100个事件，但tcpdump显示通过lo传入的99个事件。因此，也许一个人没有进入“$rcv

浏览 1提问于2017-04-28得票数 0

3回答

RxJ首先允许n个请求，然后允许延迟

javascript、typescript、rxjs、observable

我希望使用RxJ从具有n接口的服务中请求Observable记录。该服务有一个DDoS保护机制，所以如果我立即请求，即1000个记录，我将被阻塞几分钟。我对每个记录的静态延迟为1秒，如下所示： .concatMap我想知道是否有一种优雅的方法，不需要任何等待时间就能获得第一张记录，即10份记录，然后再

浏览 3提问于2017-08-09得票数 1

回答已采纳

1回答

如何使用neo4j java驱动4.0.0批量流式传输记录？

java、neo4j、driver

假设我有一个对neo4j过程的查询，它应该返回100000条记录。我想要的是一种批量获取我的记录的方法。我不想等待100000条记录全部由Neo4j发送，我想在客户端控制我收到的记录的数量。我注意到在ResultCursor中有一个CompletionStage<Record> nextAsync()方法，它做我想做的事情，但只有一个记录。这并不是最优的，因为它需要在客户端和neo4j之间往返太多次才能获

浏览 14提问于2020-03-04得票数 0

回答已采纳

2回答

SQL:删除旧消息，但每个用户的最后X条消息除外

mysql、sql、postgresql

然而，我不想让它看起来像一个用户没有活动，所以我想在每个流中留下最少的X个帖子。简化后，我的“消息”表有一个"mid“(消息ID，主键)、一个"uid”(用户ID)、一个“创建”日期(UNIX时间戳)和一个“消息”。WHERE uid = m.uid ORDER BY mid LIMIT 1 OFFSET ?)但是，当我在NOT IN()内部单独尝试查询时，它不返回任何结果。此外，我认为它不适用于从您要删除的同一个表中执行SELECT。如果有必要，我可以进行两个查询，但我希望这不是必需的。我试着

浏览 0提问于2011-07-14得票数 3

回答已采纳

1回答

如何知道我的记录是否已使用Spring手动提交

apache-kafka、kafka-consumer-api、spring-kafka

countDownLatch.countDown(); } 我正在按春季卡夫卡文档编写acknowledgement，但这只意味着我的消息被标记为发送的是否有一个返回的commitId或某个值？我的想法是知道某一特定的消费者记录是否被消费。我想为内部跟踪的目的储存价值。卡夫卡是否在内部维护消费者记录上的任何状态，比如(Acknowledged，提交的，Not Committed)，这对分类很有帮助。这将真正帮助我区分消耗

浏览 10提问于2017-02-23得票数 2

1回答

java -如何在kafka中显示每个分区而不是每个记录？

java、apache-kafka、partition、consumer

我的当前代码显示给定输入的每条记录(或每行数据)。如果我有10个分区和15行数据，它将显示15行和多个分区实例。offsetrecord.add(record.offset());代码输出：预期输出显示的是每个分区的一个实例，而不是每个记录

浏览 29提问于2018-10-18得票数 1

1回答

将数据从neo4j 2.0 M06移动到neo4j 2.0 match不返回任何结果

neo4j、cypher

我一直在使用M01 to M06测试neo4j。每次下载新版本到数据目录时，我都可以复制graph.db目录，而且它似乎总是运行正常。但我只是下载了neo4j 2.0的GA版本。当我尝试运行一个简单的查询时 "Match (n:Flight) return n limit 25“它返回0条记录。事实上。所有匹配(n:标签)返回n限制25总是返回0条记录。

浏览 1提问于2014-01-22得票数 1

1回答

splunk查询在转换为表格式时不显示所有记录

splunk-query

spath input=Message | search FileName=* | rename event.Values.Connections{}.ClientName as ThirdParty 此查询返回N个记录，但只要我应用下面的过滤器 | dedup FileName| table FileName, ThirdParty | fillnull value=N/A | sort ThirdPartydesc 查询仅显示N-M条

浏览 31提问于2019-01-09得票数 0

回答已采纳

1回答

与PostgreSQL同步使用CAMEL

web-services、spring、apache-camel

我有Spring WS，它在SOAP请求后在数据库中创建一条记录，然后它应该等待响应出现。(我在DB中有两个表- requestTable -record是在对WS的请求到来时创建的，而responseTable记录是由独立的源创建的)。当方法检测到与请求链接的记录出现在responseTable中时，WS将发送正确的响应。问题出在同步上，因为我不能(实际上我可以但我不想)创建一个等待n秒的线程，我想用CAMEL来实现它，我在某处读到

浏览 0提问于2012-11-29得票数 0

回答已采纳

点击加载更多