腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(4412)
视频
沙龙
2
回答
Apache
Pulsar
vs Kafka -消费者是否会拉出(投票)
消息
?
apache-kafka
、
kafka-consumer-api
、
apache-pulsar
我知道在Kafka中,消费者从代理主题中拉出
消息
(拉出)?谢谢
浏览 2
提问于2020-04-10
得票数 4
2
回答
如何避免Apache
Pulsar
中不
活动
主题的自动删除
message-queue
、
apache-pulsar
我有一个应用程序,该应用程序在特定主题下向
Pulsar
生成
消息
,并在该应用程序完成后关闭该应用程序;同时,不存在用于读取该主题的使用者。过了一段时间,当我创建一个使用者并想要读取写入的数据时,我发现所有的数据都丢失了,因为我编写的主题被
Pulsar
删除了。 如何在
Pulsar
中禁用非
活动
主题的自动删除?
浏览 0
提问于2019-07-24
得票数 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
回答已采纳
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
回答已采纳
2
回答
在Apache主题中删除/终止所有
消息
的最有效方法是什么?
apache-pulsar
我试图找出从
Pulsar
主题中删除所有
消息
的最佳方法(无论是逻辑上还是物理上的),这样它们就不再可供订阅使用了?我知道我们可以简单地做$
pulsar
-admin persistent delete persistent://tenant/namespace/topic。但是,这个解决方案有一些缺点:它完全删除了主题(因此我们必须在以后重新创建它),那么就不应该有连接到它的
活动
客户端(即订阅或生产者)。或者,是否有一种方式以编程方式使两个MessageId之间的所有
消息</e
浏览 3
提问于2020-10-16
得票数 3
回答已采纳
3
回答
Apache
消息
传递语义
queue
、
message-queue
、
apache-pulsar
我研究了Apache文档中的
消息
传递语义。Apache函数所提到的传递语义(至少一次、最多一次和有效一次),如果我们不使用Apache函数,那么有哪些不同的交付语义可用呢?
浏览 8
提问于2020-04-30
得票数 3
回答已采纳
1
回答
从Sun JMS桥到ActiveMQ再到.NET
activemq
我有Sun的
消息
队列
4.3。使用imqbroker守护程序的本地主机上的默认安装。已打开一个
队列
。我知道有ActiveMQ解决方案,5.3
版
。已检查.NET的ActiveMQ (版本1.1),它对于类似于Sun的ActiveMQ
队列
工作正常。我的问题是,我希望将现有的SunMQ4.3连接到一个ActiveMQ
队列
,而中的文档并不是很清楚。谁能准确地指出如何将activemq的配置文件映射到桥: imqbroke
浏览 4
提问于2009-11-03
得票数 0
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
2
回答
如何在Apache
Pulsar
集群之间迁移数据?
apache-pulsar
人们如何在
Pulsar
环境之间迁移数据,以进行灾难恢复或蓝绿色部署?他们是将数据复制到新的亚马逊网络服务区域还是K8S命名空间?
浏览 59
提问于2021-09-09
得票数 2
1
回答
Jenkins没有在SQS
消息
到达的基础上启动构建
build
、
jenkins
、
jenkins-plugins
、
amazon-sqs
工具: 我想知道我们缺少了什么?最后SQ
浏览 2
提问于2013-03-20
得票数 0
回答已采纳
3
回答
在带有HornetQ的JBoss 7中,JMS Queue的“耐久”属性是什么意思?
java
、
jakarta-ee
、
jms
、
jboss7.x
、
hornetq
在使用HornetQ在JBoss 7上配置JMS
队列
(基于standalone-full.xml配置)期间,我注意到一个属性‘耐久’。JBoss 7 HornetQ中的此属性是否指临时
队列
?或者这个属性是指某种非临时的、非持久的
队列
?
浏览 0
提问于2012-12-11
得票数 15
回答已采纳
2
回答
RabbitMQ锁定
消息
组
rabbitmq
、
queue
在这里,每个用户都有自己的
队列
,并附加了一个使用者。我们在这里面临的挑战是,如何在创建新
队列
时自动启动消费者,并在
队列
一段时间未使用的情况下可能停止消费者? 提前感谢
浏览 22
提问于2020-07-28
得票数 0
回答已采纳
2
回答
Apache
Pulsar
发送
消息
似乎很慢
c#
、
.net
、
apache-pulsar
今晚,我开始对Apache的
消息
生成器进行一些测试,并且使用官方的.net库(DotPulsar),我发现与其他
消息
相比,
消息
的发送非常慢。public/default/mytopic"; .ServiceUrl(new Uri("
pulsar
浏览 5
提问于2022-04-18
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列上云挑战与方案:腾讯云的 Apache Pulsar 实践
急需降低系统复杂性,我们从Kafka迁移到了Pulsar
对Kafka 和 Pulsar进行性能测试后,拉卡拉将消息平台统一换成了 Pulsar
消息传输的设计方式(下)
Apache 开源超级项目Pulsar
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券