腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(847)
视频
沙龙
2
回答
Apache
Pulsar
vs Kafka -消费者是否会拉出(投票)
消息
?
apache-kafka
、
kafka-consumer-api
、
apache-pulsar
我知道在Kafka中,消费者从代理主题中拉出
消息
(拉出)?谢谢
浏览 2
提问于2020-04-10
得票数 4
1
回答
Pulsar
用户中“最新”和“最早”的意外行为
apache-pulsar
从文档中:“最早”= FIFO
队列
。在创建订阅之前,最新
消息
会忽略所有
消息
。然后,它成为一个FIFO
队列
,从创建订阅的点开始。receiving messageReceived message 'b'Hello-10-lifo-v3'' id='(15537,40,-1,-1)
浏览 3
提问于2021-09-16
得票数 0
4
回答
与Apache
Pulsar
相比,Kafka的优点和缺点是什么
apache-kafka
、
apache-pulsar
雅虎开发了
Pulsar
,pub-sub
消息
系统,并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道,卡夫卡相对于脉冲星的主要正负点。
浏览 1
提问于2017-09-05
得票数 56
1
回答
通过
Pulsar
使用者大量读取
消息
apache-pulsar
我使用节点脉冲星客户端来使用来自
pulsar
主题的
消息
。使用者使用shared订阅模式订阅主题。当前,每次对receive的调用都会从主题中获得一条
消息
。是否有一种大容量接收
消息
的方法?
浏览 4
提问于2020-06-03
得票数 1
2
回答
Apache-
Pulsar
吞吐量
node.js
、
throughput
、
apache-pulsar
我在我的本地机器上运行apache-
pulsar
单机
版
,作为
队列
系统的docker容器,并将1000个作业推送到一个主题(假设是“demo”)。我不确定我是否遗漏了一些所需的配置,或者是否需要多个
pulsar
brokers,或者我应该如何做,以便如果我增加消费者,消费吞吐量也应该增加(例如在2个消费者的情况下大约40-45秒)。Docker图像: apachepulsar/
pulsar
消费选项:"subscriptionType":"Shared",&
浏览 26
提问于2019-12-18
得票数 2
1
回答
并行化
Pulsar
使用者工作负载的最佳方法是什么?
java
、
multithreading
、
apache-pulsar
我想使用
Pulsar
作为
消息
队列
,使用共享消费者和Java客户机。目前,没有严格的排序要求,也没有分区。由
消息
触发的任务通常需要2秒。在一个应用程序实例中,应该选择下列两种方法中的哪一种来分割线程之间的工作,这其中是否有明确的首选: 1使用者的接收
队列
大小为100,线程池中有10个线程在循环中调用consumer.receive(),10的接收
队列
大小为10,使用MessageListener接口并在原始MessageListener.receive()调用.中运行任务。
浏览 6
提问于2020-07-15
得票数 0
1
回答
在Java/Scala程序中从DataStream创建SQL Table,并从SQL Client CLI - Apache Flink查询它
scala
、
apache-flink
、
flink-streaming
、
flink-cep
、
flink-sql
是否可以使用Flink SQL client CLI与表交互,其中哪个表是在集群中运行的Scala/Java程序中创建的?
浏览 14
提问于2019-05-09
得票数 0
回答已采纳
2
回答
如何避免Apache
Pulsar
中不活动主题的自动删除
message-queue
、
apache-pulsar
我有一个应用程序,该应用程序在特定主题下向
Pulsar
生成
消息
,并在该应用程序完成后关闭该应用程序;同时,不存在用于读取该主题的使用者。过了一段时间,当我创建一个使用者并想要读取写入的数据时,我发现所有的数据都丢失了,因为我编写的主题被
Pulsar
删除了。 如何在
Pulsar
中禁用非活动主题的自动删除?
浏览 0
提问于2019-07-24
得票数 4
回答已采纳
1
回答
Apache
pulsar
-函数执行不会影响输出
java
、
apache-pulsar
、
pulsar
将其复制到我的
pulsar
stanalone docker中,并运行以下命令: ./bin/
pulsar
-admin functions create --classname org.example.test.ExclamationFunction --jar java-function/bin/
pulsar
-admin functions trigger --tenant public --namespace default --name JavaFunction --triggerValue&q
浏览 12
提问于2021-02-16
得票数 0
回答已采纳
2
回答
用于Apache与miniO Lake (java.lang.IllegalArgumentException)的德尔塔湖水槽连接器
java
、
docker
、
delta-lake
、
apache-pulsar
: command: bin/
pulsar
standalone ports-2.9.3.jar:2.9.3]我做错了什么是
浏览 19
提问于2022-09-20
得票数 1
回答已采纳
1
回答
为什么在Apache中使用MessageListeners而不是简单地使用Consumer.receive()?
java
、
apache-pulsar
Apache的API ()至少包括两种使用来自
Pulsar
主题/
队列
的
消息
的方法: 大多数情况下,使用MessageListener在
Pulsar</em
浏览 4
提问于2019-12-17
得票数 5
回答已采纳
3
回答
Apache
消息
传递语义
queue
、
message-queue
、
apache-pulsar
我研究了Apache文档中的
消息
传递语义。Apache函数所提到的传递语义(至少一次、最多一次和有效一次),如果我们不使用Apache函数,那么有哪些不同的交付语义可用呢?
浏览 8
提问于2020-04-30
得票数 3
回答已采纳
1
回答
在Flink中的不同作业之间交换数据
apache-flink
、
flink-streaming
我需要运行单独的作业,但我需要以某种方式与这两个作业通信,例如: Source1 -> Operator1 -> Sink1 Source2 -> Operator2 -> Sink2 在某些情况下,我需要在job2中知道来自job1的Operator1何时触发某些东西,然后在job2中启动Operator2,或者只是对来自job2中的job1的Operator1结果执行一些操作,例如,跳过而不说任何疯狂的事情。 致以亲切的问候。
浏览 13
提问于2020-06-30
得票数 0
1
回答
NServiceBus,什么时候
消息
用的太多?
soa
、
nservicebus
当在NServiceBus中考虑一个服务时,你会在什么时候开始质疑一个服务处理多少
消息
是太多了,并开始将这些
消息
分解成一个新服务?考虑以下几点:我有一个销售服务,目前可以分为几个不同的业务组件,它们是销售订单验证、销售订单处理、
采购
订单验证和
采购
订单处理。 目前在此服务中使用了大约20个
消息
处理程序和2个sagas。我担心的是,在我网站的高流量期间,这可能会导致最初的
消息
峰值跃升至数百条。考虑到需要按照从
队列
中取出
消息
的顺序来处理
消息
浏览 1
提问于2013-03-19
得票数 0
1
回答
如何在Masstransit/RabbitMQ中组织
队列
?
rabbitmq
、
message-queue
、
servicebus
、
masstransit
、
messagebroker
我有一个api (承载一个总线实例),它发布
消息
。这些
消息
是不同的,因为这个api不是一个微服务(用于购买、销售等的
消息
)。 用于
队列
类型的一个进程?进程(按域分组
队列
)的多个
队列
?例如,有一个进程让多个消费者消费与
采购
相关的
消息
,并管理不同的
队列
,如purchases.stock、purchases.suppliers.这个选择对我来说更有意义,但我不确定。
浏览 3
提问于2017-10-20
得票数 6
回答已采纳
1
回答
在SQL-Server表中存储事件
消息
c#
、
events
、
asp.net-web-api
、
messages
、
stomp
我有一个创建
采购
订单的Web API。一旦创建了此
采购
订单,我必须通过该服务的API调用向另一个第三方web服务确认创建。在成功创建订单时,我希望将事件/
消息
存储在Sql Server表中以调用第三方API。我倾向于以STOMP/STOMP-like的格式存储这些内容。注意:目前,我不打算使用真正的
消息
队列
。我也不希望引发同步事件来调用第三方API。
浏览 2
提问于2014-01-30
得票数 0
2
回答
Apache
Pulsar
发送
消息
似乎很慢
c#
、
.net
、
apache-pulsar
今晚,我开始对Apache的
消息
生成器进行一些测试,并且使用官方的.net库(DotPulsar),我发现与其他
消息
相比,
消息
的发送非常慢。public/default/mytopic"; .ServiceUrl(new Uri("
pulsar
浏览 5
提问于2022-04-18
得票数 1
2
回答
在崩溃的情况下保持Akka状态
scala
、
persistence
、
akka
、
fault-tolerance
其他一些系统(我被告知JMS就是其中之一)更进一步,持续持久化参与者之间发送的
消息
。这样,如果机器在物理上崩溃--比如说由于硬件故障--仍然可以将状态恢复到故障之前的状态。
浏览 0
提问于2012-10-05
得票数 4
回答已采纳
1
回答
在哪些情况下,使用
消息
队列
比使用Twitter Storm更好
message-queue
、
apache-storm
我正在阅读Twitter Storm,它似乎为构建数据管道提供了比
消息
队列
更高级别的抽象。我想知道在什么情况下(如果有),直接使用
消息
队列
而不是Storm会更好。
浏览 1
提问于2014-11-04
得票数 0
1
回答
如何使用RabbitMQ处理蓝/绿部署?
testing
、
rabbitmq
、
integration
、
amq
然而,这变得很棘手,因为新代码在
队列
中为正在部署的服务注入
消息
,而现有实例(以前的版本)仍在运行。我们有一个蓝/绿部署。对于RabbitMQ来说,有可能有许多监听器监听一个
队列
,但只监听一个特定的版本吗?例如,所有正在运行的服务器都会读取2017.10.20
版
(以前的版本)或更早版本的
消息
,但不会读取较新版本的
消息
。 这样,我就可以部署一个新的服务,而其他read都不会读取它的测试
消息
。它生成和使用与当前运行的服务相同的
消息
类型。
浏览 27
提问于2017-12-19
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列上云挑战与方案:腾讯云的 Apache Pulsar 实践
急需降低系统复杂性,我们从Kafka迁移到了Pulsar
对Kafka 和 Pulsar进行性能测试后,拉卡拉将消息平台统一换成了 Pulsar
Apache 开源超级项目Pulsar
CTO观点:如何为企业选择合适的消息系统?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券