腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(38)
视频
沙龙
1
回答
我们能不能同时将动态数据流的数据发送到Kinesis和Firehose而不丢失数据?
例如:如果我在数据流中有1000条记录,我想把它同时发送到Kinesis和Kinesis,也就是说,Kinesis和Firehose都应该分别获得1000条记录。有可能吗?
浏览 3
提问于2022-04-26
得票数 0
2
回答
我是否可以说,java.util.stream.Stream中的peek()方法应该是幂等的
、
、
)中的方法,在Oracle认证的专业Java 8学习指南>第4章函数式编程>使用流>使用公共中间操作一书中,有人指出peek()的目的是在不改变结果的情况下执行操作 我的问题是:我是否可以说,实际上(
消费者行为
浏览 0
提问于2018-04-28
得票数 0
1
回答
5G核心API和向后不兼容的更改
在3 3GPP 29501的6.3节中,有关于5G核心API的向后兼容/不兼容API更改的信息。例如,假设版本1.0.0中有一个整数属性"foo“限制在0到10之间的值。如果在以后的版本中将间隔更改为0到20之间的值,那么这是否被认为是向后兼容的?
浏览 3
提问于2021-09-29
得票数 0
1
回答
我可以将BlockingCollection用于网络数据包缓存系统吗?
、
、
、
我试图通过使用BlockingCollection来实现包生产者-
消费者行为
,但是我很难理解它上的文档。
浏览 2
提问于2014-11-18
得票数 1
回答已采纳
4
回答
AWS SageMaker -实时数据处理
、
我的公司做在线
消费者行为
分析,我们使用我们从各个网站收集的数据(嵌入我们的java脚本)进行实时预测。
浏览 0
提问于2018-11-05
得票数 4
回答已采纳
1
回答
卡夫卡
消费者行为
、
我正在编写Kafka consumer,我有一个与consumer进程相关的查询。另外,假设已经在broker上创建了"topic1",而"topic2"尚未创建。我的问题是,只有在创
浏览 2
提问于2015-10-14
得票数 1
1
回答
NetLogo
消费者行为
模型
、
我将对我的模型做一个简短的描述:两个市场(蓝色方块):肉类和替代品(可供消费的产品而不是肉类)市场to go marketend ask turtles [b
浏览 3
提问于2021-04-14
得票数 1
2
回答
生产者/消费者示例使用Stream.Synchronized -消费者没有获得任何数据
、
、
、
我从来没有得到任何关于
消费者行为
的数据。
浏览 2
提问于2017-01-19
得票数 0
1
回答
避免Kafka数据中心之间的重复数据处理
在主动-主动Kafka设计中,当数据从DC1复制到DC2 (具有相同或不同区域)时。如何确保DC2使用者不会处理DC1使用者已经处理过数据?应该做什么Kafka级别的配置?
浏览 11
提问于2021-02-10
得票数 0
1
回答
SageMaker终端Lambda中的实时数据预处理
、
、
、
、
我正在做一个网站上的
消费者行为
分析项目,并实时预测用户的恶意活动。为用户进行的每一次点击收集点击数据。 我正在使用多个AWS服务,如kinesis stream、Lambda和sagemaker。
浏览 25
提问于2021-06-07
得票数 1
回答已采纳
1
回答
如何使用pika异步消费来自一个客户的2个RabbitMQ队列
、
、
2->用于控制
消费者行为
的命令消息(由消费者动态声明,并使用特定格式的路由关键字绑定到现有的交换(每个消费者运行的实例需要一个)) 我正在使用选择连接进行异步消费。
浏览 2
提问于2015-08-20
得票数 2
1
回答
ReceiveFrom方法与
消费者行为
的困惑
、
、
、
我想用RabbitMq创建一个队列,在其中我将在一边发送一些消息,然后在另一个应用程序中接收消息。我这样做的代码如下: { prefetch < 1 ? 1 : prefetch); x.UseRabbitM
浏览 4
提问于2017-10-17
得票数 0
回答已采纳
2
回答
数据仓库和Django
、
、
我目前正在构建一个商业网站/社交网络,它需要存储大量数据,并使用这些数据来进行分析(
消费者行为
)。 我使用的是Django和一个PostgreSQL数据库。
浏览 0
提问于2012-04-10
得票数 5
回答已采纳
1
回答
如何在Kafka中维护消息的排序?
我们有消息层的需求,我们希望消息的顺序被保留,直到它被消费者消费。我们正在探索同样的Kafka。 properties in the form key=value to
浏览 0
提问于2017-02-02
得票数 2
1
回答
卡夫卡消费者在CommitFailedException之后不停地浏览一堆信息
、
我正在运行一个多线程卡夫卡091消费者新。当我必须停止使用者并重新启动时,我遇到了问题。使用者一直在尝试处理上一次运行中没有使用的偏移量(其中大约有100次)。但这条信息一直在失败。2016-10-21 14:22:55,
浏览 1
提问于2016-10-21
得票数 0
回答已采纳
1
回答
active-mq artemis springboot集群主题负载平衡(循环)问题
、
、
discovery-group-ref discovery-group-name="my-discovery-group"/>
消费者行为
浏览 1
提问于2018-01-12
得票数 0
回答已采纳
2
回答
Kafka SimpleConsumer (低级消费者)用例/优势
、
只有SimpleConsumer API才能控制每个使用者从哪个分区检索数据,据说它具有更好的偏移管理。有人能详细解释一下,在什么情况下,这种精细的谷物控制是在使用不太复杂的高级消费者时需要的。谢谢。
浏览 4
提问于2016-07-08
得票数 2
回答已采纳
2
回答
当制片人比消费者更快的时候,有什么合适的方法来抑制发送给akka演员的工作呢?
问题的根源在于生产者比
消费者行为
者快得多。 我一直在滚动自己的解决方案,添加等待状态,并测量进程的平均时间,以保持稳定的作业数量,而不会炸掉参与者消息队列。
浏览 3
提问于2017-01-22
得票数 1
回答已采纳
1
回答
使用JMS和JMSXGroupID的Oracle不会导致“粘性”消费者
、
、
、
INFO Log - This is Message 285 In JMSXGroup: Group B | To Thread Thread-3 Oracle和Amazon没有表现出相同的“粘性”
消费者行为
浏览 2
提问于2021-05-04
得票数 0
回答已采纳
1
回答
spring兔最大消费者连接重试
我正在尝试建立从我的应用程序到兔子经纪人的最大重试次数。我有重试拦截器public RetryOperationsInterceptor retryOperationsInterceptor() { .maxAttempts(CommonConstants.MAX_AMQP_RETRIES) .build();这个在侦听器容器中使用, contai
浏览 4
提问于2017-02-21
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消费者行为模型,提升广告效果的利器
新冠疫情消费者行为态度影响与趋势报告
通过大数据精准营销系统洞察消费者行为,找到商机!
Tobii日本推出基于眼球追踪的VR消费者行为分析解决方案
谷歌购物在德国不再流行
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券