腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
批量
消费者
删除
元素
java
、
concurrency
storage = new ArrayList<>(); } } 我的问题是,当我在batchConsumer回调中检查传递的storage对象时,它从来没有batchSize
元素
浏览 30
提问于2020-07-28
得票数 0
回答已采纳
2
回答
实现生产者和批处理
消费者
模型的最简单的java方法
java
、
apache-kafka
、
producer-consumer
我需要生产者一个接一个地生产数据,而
消费者
将
批量
消费数据(除非队列有足够的
元素
,否则会阻塞)。但java BlockingQueue似乎只支持
消费者
一个接一个地消费数据。
浏览 35
提问于2019-12-18
得票数 3
1
回答
我应该在什么情况下使用批处理使用者与单记录使用者
spring-kafka
据我所知,Apache Kafka文档中没有诸如批处理
消费者
之类的特殊概念,但spring-kafka可以选择使用以下代码片段创建批处理
消费者
。factory.setBatchListener(true); // <<<<<<<<<<<<<<<<<<<<<<<<<} 现在我的问题是, 我应该在什么时候使用
批量
消费者</em
浏览 17
提问于2020-10-21
得票数 0
回答已采纳
1
回答
单记录kafka
消费者
和kafka
批量
消费者
的基本区别是什么?
spring-kafka
我正在使用spring-kafka 2.2.8,试图理解单个记录
消费者
和
批量
消费者
之间的主要区别是什么。 据我所知,从一个主题中读取消息/字节对于单个记录
消费者
和
批量
消费者
来说没有什么不同。
浏览 170
提问于2020-10-17
得票数 0
回答已采纳
0
回答
RabbitMQ批处理消息
rabbitmq
RabbitMQ是否支持生产者端
批量
发送消息,
消费者
端
批量
消费消息?就像Kafka一样,它存储
批量
产生的消息,直到达到linger.limit,或者直到
批量
满!
浏览 7
提问于2017-06-15
得票数 2
回答已采纳
1
回答
如何配置kafka
批量
消费者
使用SeekToCurrentBatchErrorHandler重试预先定义的次数?
spring-kafka
我正在使用spring-kafka '2.2.7.RELEASE‘来创建一个
批量
消费者
,我正在尝试理解如何配置一个kafka
批量
消费者
来使用SeekToCurrentBatchErrorHandler重试预先定义的次数
浏览 98
提问于2021-05-18
得票数 0
回答已采纳
1
回答
Kafka有
批量
消费者
吗?
apache-kafka
高级
消费者
API似乎是一次读取一条消息。如果
消费者
想要处理这些消息并将其提交给其他下游
消费者
,比如Solr或Elastic-Search,这对他们来说可能是一个很大的问题,因为他们更喜欢
批量
发送消息,而不是一次只有一个。在内存中对这些消息进行批处理也不是一件容易的事,因为Kafka中的偏移量只有在批处理已经提交时才需要同步,否则具有未提交下游消息的崩溃的kafka
消费者
(如Solr或ES)的偏移量将已经更新,从而导致消息松散如果
消费者
在向下游提交消息之后但在更新消息偏移量之前崩溃,那么它
浏览 2
提问于2016-03-04
得票数 9
1
回答
使用nats按批处理消费和提交的最佳方式是什么
jetstream
、
nats.io
我需要一批一批地使用jetstream中的流,并在数据库
批量
插入后确认地将
批量
存储在数据库中,此时我使用了pull consumer,存储所有消息,并在
批量
插入成功时逐个提交。我需要确认所有消息吗?我看到我可以提交最新的消息,但为此我需要处于
消费者
推送模式
浏览 18
提问于2021-04-20
得票数 0
1
回答
如何在python中每隔30分钟消费一次kafka队列
apache-kafka
、
kafka-consumer-api
、
kafka-python
我在python中遇到了一个关于kafka
消费者
的问题,这是我的用例,kafka生产者将以实时流的形式每秒发送数据。但kafka
消费者
需要每30分钟消费一次,采集
批量
数据。帮我解决这个问题。
浏览 139
提问于2019-03-15
得票数 1
回答已采纳
1
回答
如何在受访
消费者
(PollableMessageSource )中处理
批量
记录?
apache-kafka
、
batch-processing
、
spring-cloud-stream
我的
消费者
看起来像这样: @Bean public ApplicationRunner runner(PollableMessageSource input, MessageChannel output
浏览 47
提问于2020-11-24
得票数 0
回答已采纳
1
回答
B+树中的
批量
删除
algorithm
、
tree
从B+树中
删除
单个
元素
就可以了。然而,我想知道是否有某种方法可以在至少O(nlogn)时间内
删除
树中的大量
元素
。 如果它们在链表中碰巧是连续的,是否可以同时
删除
树的
批量
元素
?
浏览 1
提问于2016-05-12
得票数 1
1
回答
批量
删除
PDF
元素
javascript
、
pdf
、
adobe
、
batch-processing
我需要
删除
设计室放在文件中的剪切标记,然后才能将页面裁剪到8.5x11。 问题是,手动完成此操作将需要很长时间,而且我没有时间手动处理这么大的数据量。
浏览 0
提问于2016-02-02
得票数 0
5
回答
删除
jquery中的下一个
元素
和选定的
元素
javascript
、
jquery
、
html
我将
批量
删除
id以leg-开头的所有div
元素
$('div[id^="leg-"]').remove(); 我还想
删除
每个div后面的<hr>
元素
: <div id="leg-1"> <hr> 没有触发事件,这就是为什么我不能像这样选择
元素
: $(this).next(); 我该怎么做呢?
浏览 56
提问于2016-07-18
得票数 0
回答已采纳
1
回答
批量
分配,用户与管理员,以正确的方式更新记录?
php
、
laravel-5
我已经从
批量
赋值数组中
删除
了一个
元素
。但是,现在用户可以在表单中传递
元素
并覆盖字段,这是不可取的。希望我不需要有两个用户模型?
浏览 12
提问于2016-08-26
得票数 0
2
回答
增加Kafka
消费者
单次轮询的消息阅读量
apache-kafka
如何进一步增加单个
消费者
读取的消息数?
浏览 0
提问于2018-08-09
得票数 31
回答已采纳
1
回答
用于实时数据处理的多种用户的Kafka
performance
、
lucene
、
stream
、
apache-kafka
、
message-queue
消费者
消费的数据如下:使用者2-从主题中
批量
使用数据。
浏览 5
提问于2017-06-14
得票数 1
1
回答
Magento2 -
批量
操作
消费者
问题
magento2
、
schedule
、
bulk
、
consumer
、
operations
我正在尝试创建一个发布者和一个
消费者
来处理一个大的导入。我已经成功地设置了发布者,以便将消息推送到队列,问题是没有调用
消费者
来读取消息和执行计划的操作。有没有一个cron来处理这件事,或者应该在
批量
创建之后调用
消费者
? 谢谢!
浏览 7
提问于2018-09-12
得票数 0
2
回答
关于PECS java泛型
java
、
generics
有人能解释一下Joshua Bloch所说的生产者/
消费者
吗?
浏览 0
提问于2010-12-27
得票数 1
回答已采纳
1
回答
是否有任何消息队列支持基于优先级的消息?
message
、
priority-queue
我有一个要求,
消费者
需要首先使用队列中的高优先级消息。此外,如果它支持
批量
获取消息将是好的?
浏览 1
提问于2014-07-17
得票数 1
回答已采纳
1
回答
批量
消费骆驼卡夫卡
java
、
apache-kafka
、
apache-camel
我无法与卡夫卡骆驼的
消费者
批量
阅读,尽管下面的例子张贴在这里。我是否需要对我的生产者进行更改,还是我的
消费者
配置最有可能出现问题? from(kafkaReadingConsumerEndpoint)}
浏览 1
提问于2022-02-18
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
魅力python——添加新元素、删除元素、替换元素
单链表,头插法,尾插法,插入元素,删除元素
python爬虫集合,函数,元素,字典,删除
Outlook如何批量删除邮件?
批量删除微博小巧思
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券