在Pulsar中，有没有一种方法可以清理没有附加消费者的旧的持久订阅？
在Pulsar中，可以使用Pulsar Admin命令行工具来清理没有附加消费者的旧的持久订阅。具体的方法是使用pulsar-admin persistent delete-subscription命令来删除指定的持久订阅。
该命令的语法如下：
pulsar-admin persistent delete-subscription [options] persistent://tenant/namespace/topic -s subscription其中，persistent://tenant/namespace/topic是要删除订阅的主题的完整名称，-s subscription是要删除的订阅的名称。
清理没有附加消费者的旧的持久订阅可以帮助释放资源并提高系统性能。这在一些场景下非常有用，例如当订阅者不再需要某个特定的持久订阅时，可以通过清理操作来删除该订阅。
推荐的腾讯云相关产品是腾讯云消息队列 CMQ，它是一种高可靠、高可用的分布式消息队列服务，适用于大规模分布式系统的消息通信。CMQ提供了消息的可靠投递和顺序消费能力，支持多种消息协议和多种消息模式，可以满足不同场景下的消息通信需求。
腾讯云消息队列 CMQ产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
1回答
关于“投递 Subscription 指topic像订阅者投递消息的过程” 对应英文的问题？
官方文档、消息队列 CMQ 版
"投递 Subscription 指topic像订阅者投递消息的过程" <----- 这个是不是“deliver"，或transfer / transmit, 这是一个动作，subscription是A向B订阅的意思。
标题：名词解释 - 消息队列 CMQ - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/406/4552
浏览 302提问于2018-02-15
2回答
在Apache主题中删除/终止所有消息的最有效方法是什么？
apache-pulsar
我试图找出从Pulsar主题中删除所有消息的最佳方法(无论是逻辑上还是物理上的)，这样它们就不再可供订阅使用了？
我知道我们可以简单地做$ pulsar-admin persistent delete persistent://tenant/namespace/topic。
但是，这个解决方案有一些缺点:它完全删除了主题(因此我们必须在以后重新创建它)，那么就不应该有连接到它的活动客户端(即订阅或生产者)。
或者，是否有一种方式以编程方式使两个MessageId之间的所有消息对订阅不可用？
谢谢
浏览 3提问于2020-10-16得票数 3
回答已采纳
1回答
ActiveMQ主从故障切换丢失消息
c++、activemq、activemq-cpp
涉及故障转移时(仅针对主题)，ActiveMQ会丢失大量消息。生产者在主题中写入1000条消息，而消费者(同时)从同一主题中阅读。在这个过程中，我关闭了ActiveMQ主服务器，这个过程在ActiveMQ从服务器上继续进行。在进行转换时，会丢失大量消息(大约100条消息)。我正在开发的产品涉及到不丢失消息。我可以为主题的持久化做些什么？制片人：
#include <activemq\library\ActiveMQCPP.h>
#include <cms\Connection.h>
#include <cms\Session.h>
#include <
浏览 45提问于2019-11-06得票数 0
2回答
如何在JMS中接收确认
java、jms、publish-subscribe
这是我的场景。该程序采用发布者/订阅者方法开发。在生产者和消费者部分有两个主题(topic1，topic2)。我需要在生产者程序中获得消费者对接收到的topic1的确认，这样当确认状态为真时，生产者程序将不得不在topic2上发送消息。
有谷歌链接建议session.CLIENT_ACKNOWLEDGE在消费者。但我需要将确认状态返回给producer，以便进一步处理。
浏览 3提问于2013-01-22得票数 1
1回答
如何读取主题的保留消息
c#、ibm-mq
我有一个web应用程序，它将消息发布到某个主题，然后是几个订阅这些主题的Windows服务，其中一些具有多个实例。如果消息发布时服务正在运行，那么所有消息都能正常工作，但如果它们不能正常运行，则消息将保留在订阅该主题的队列上，但在服务启动备份时不会读取。
想要的行为-
当消息发布到主题字符串MyTopic时，只从MyTopicQueue读取一次。我使用一些通配符主题，以便将每条消息发送到多个队列，但是服务的多个实例订阅相同的主题字符串，并且每条消息都应该仅由这些实例读取。
如果消息发布时MyTopic主题的订阅者不在网上，则消息将保留在MyTopicQueue.上。
当订阅特定主题的服务重新联
浏览 6提问于2022-03-03得票数 2
回答已采纳
1回答
保留消息，直到使用Python + Stomp进行订阅
python、python-2.7、message-queue、stomp
我目前正在使用stomp客户端库编写两个脚本来订阅消息服务器，write.py用于编写数据，read.py用于获取数据。
如果我先启动read.py，然后运行write.py，write.py将正确地接收消息。
但是，如果我先运行write.py，然后运行read.py，则read.py不会检索以前发送给服务器的任何消息。
下面是脚本的相关部分。
在write.py订阅和检索消息之前，如何实现将read.py放入队列中的消息保留下来？
write.py
def writeMQ(msg):
queue = '/topic/test'
conn = stomp.Co
浏览 1提问于2016-08-25得票数 0
回答已采纳
9回答
如何快速入门Kafka消息队列？
消息队列 CMQ 版、消息队列 CKafka 版
最近经常听到这个名词，但是不知道如何入门，我看到腾讯云也有相关的产品Ckafka产品，所以来问问~
浏览 4970提问于2018-09-14
1回答
带有ARTEMI2.6.3多播的Spring WebSocketMessageBrokerConfigurer (主题)无效
spring-boot、websocket、spring-websocket、stomp、activemq-artemis
Artemis残播地址和队列没有预期的行为。我的想法是创建组或特定的消息给用户，可以有多个websocket会话(web，android等)。服务器将向artemis多播地址发布通知，所有订阅者都应收到通知。在现代场景中，我只是强迫用户'luislaves00‘并创建多个会话。在artemis中，我可以看到两个消费者(不确定如何完成它的工作)，但是消费者的行为就像一个循环，而不是发行者-订阅者。使用Spring的内存代理，它可以正常工作，但不是持久的，因此当没有订阅服务器连接时，消息就会下垂。下面是我使用的代码：
客户端部分：
function connect() {
var
浏览 2提问于2018-09-30得票数 0
回答已采纳
2回答
主题中的消息存储
jakarta-ee、jms、jms-topic
在JMS中，消息以先进先出的方式存储在QUEUE.But中，在Topic的情况下，消息是如何存储的？是否在FIFO aur中有任何其他方式？
浏览 0提问于2013-01-03得票数 1
1回答
使用动态sql过滤器查询的Azure服务总线主题订阅
azure、azure-functions、azureservicebus、azure-servicebus-topics
我试图使用Azure服务总线在多个azure函数之间传递消息。我正在用代码创建主题和订阅。但不确定如何从代码中添加筛选器查询。我想通过id过滤消息。例如SqlFilter($"'id' ='{id}'")。因为这个过滤器，我不想为每条消息创建一个订阅。
是否可以为订阅设置不同的筛选器？
可以通过为每个请求创建一个订阅并随后删除该问题来解决此问题。但我不想创建这么多订阅。我的目标是每次调用函数时都更改过滤器。
样本代码：
var connectionString = ConfigurationManager.AppSettings["Ser
浏览 0提问于2017-10-02得票数 1
2回答
如何才能使activemq真正可靠？当代理断开连接消息丢失时
java、jakarta-ee、jms、activemq、apache-tomee
我们在Apache TomEE v1.6.0+中构建了一个TomEE应用程序。有两个部分，一个云部分和一个地面部分。云部分的目的是永远不要重新启动，因为它监视一个短暂的信息源，但是创建JMS消息并将它们发送给它的代理。
地面部分打算在白天重新启动，并且是复杂处理逻辑所在的地方。它也有一个连接到云代理的代理。
我们面临的问题是，如果我们将TomEE的底层实例取下来超过几分钟，然后再次启动它，云代理将不会交付堆积起来的所有消息。此外，它也不会传递任何新消息，迫使我们重新启动它，这会使我们失去消息。
这是两个连接的URI..。我们到底做错了什么？？
云：
<Resource
id=&#
浏览 4提问于2014-01-30得票数 2
回答已采纳
2回答
我怎样才能在踩踏中收到丢失的信息？
python、activemq、publish-subscribe、stomp
我有一个python脚本，它必须在linux服务器上运行24/7，并通过STOMP从另一个服务器接收ActiveMQ推送通知。它可能发生的情况是，脚本由于任何原因而失败，并将在一段时间内下降，显然最多30分钟，或者平均只有几分钟。
我需要接收丢失的消息--如果脚本之前已经关闭，那么在脚本再次启动之后，会以某种方式收到通知。据我所知，而且我的理解是有限的，这是可能的，一旦我的脚本启动，服务器就会发送它们。我相信这是真的
持久订阅是订阅主题的队列，因此即使创建持久订阅的客户端不在联机，当他返回联机时仍然可以获得发送到该主题的所有消息的副本。多个客户端可以订阅相同的持久订阅，并且由于它是由队列支
浏览 2提问于2016-02-01得票数 1
回答已采纳
1回答
从ASP.NET与WCF服务通信安全吗？
asp.net、wcf
我需要从ASP.NET (以双工方式)与Windows服务进行通信。将该服务转换为WCF服务并组织双向通信是安全的吗？
我担心的是一个场景，当服务试图通信时，但是ASP.NET进程被重新加载，消息丢失。虽然在开发过程中这是不太可能的，但我想它很可能在与许多客户的生产中。
我倾向于寻找一种解决方案，它涉及到某种持久性：
Windows和ASP.NET都将数据写入Server并通过SqlDependency得到通知
他们通过RabbitMq交换消息
浏览 1提问于2016-12-31得票数 0
1回答
ActiveMQ在大量消息(数十毫安)上的性能较差
performance、activemq
CentOS 7
4芯，16 G RAM，500 SSD
ActiveMQ 5.15.4
OpenJDK运行时环境AdoptOpenJDK (构建11.0.10+9)
ActiveMQ体系结构
机器69和68是由网络代理构建的。68和69的activemq.xml是相同的，除了代理名称、主机名、IP等相关名称之外。
该体系结构中的主题：
TOPIC_A_ALL_DELIVERED
TOPIC_A_ALL_RECEIVED
TOPIC_A_NN_DELIVERED，NN=00-23
TOPIC_A_NN_RECEIVED，NN=00-23
持
浏览 2提问于2021-02-04得票数 0
4回答
与Apache Pulsar相比，Kafka的优点和缺点是什么
apache-kafka、apache-pulsar
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
9回答
JMS主题与队列
jms、activemq
我想知道JMS队列和JMS主题之间有什么区别。
说
主题
在JMS中，主题实现发布和订阅语义。当您发布一条消息时，它会传递给所有感兴趣的订阅者--因此，对于许多订阅者来说，零将收到该消息的副本。只有在代理接收消息时具有活动订阅的订阅服务器才能获得消息的副本。
排队
JMS队列实现负载均衡器语义。一个单一的消息将被一个消费者接收。如果在发送消息时没有可用的使用者，它将一直保存到可以处理消息的使用者可用为止。如果使用者在关闭前收到一条消息而不承认它，那么该消息将被重新传递给另一个使用者。一个队列可以使许多消费者的消息负载在所有可用的消费者之间保持平衡。
我想要“一些东西”，它将以与Acti
浏览 8提问于2011-04-07得票数 228
回答已采纳
3回答
如何使用Node.js在云PubSub中控制确认
node.js、google-cloud-functions、google-cloud-pubsub
基本上我已经创建了一个云函数(写了一个Node.js代码)，它将在云发布主题的消息上触发，并将数据加载到Bigquery表中。
topic中的消息被云函数读取后被删除。我知道订阅者在内部发送确认和结果，消息从主题中删除。
我想控制发送给发布者的确认。怎么才能实现，没有找到相关的文档。
浏览 2提问于2017-10-18得票数 12
1回答
将消息保存在主题中，直到所有使用者完成处理
apache-camel、activemq、activemq-artemis
团队，我们有一个发布者，它发布请求主题的消息，并假设我们有2个消费者实例正在运行。这两个实例将从topic获取消息。一个消费者处理时没有任何问题，但其他消费者在处理过程中崩溃。因为它是不可持久的，所以当消费者获取消息时，消息已经从请求主题中删除了。现在我们不希望两个消费者都完成了，消息应该在happen.Unless中可用。我们不能在这种情况下使用持久订阅者，因为消费者实例是动态的。今天我们有2个消费者实例，明天基于负载，我们可能会再增加2个消费者实例，如果我们有持久的订阅者，我们就不能维护动态的clientId和durableSubscriptionNaem。我们对消费者和发布者使用came
浏览 2提问于2018-12-07得票数 0
1回答
Websphere具有多个使用者的主题订阅
c、ibm-mq
我有一个微服务，它在topic MQ中订阅了一个WebSphere。订阅是managed和durable。我显式地设置了subscription name，以便在从任何微服务故障中恢复之后，可以使用它连接回队列。订阅工作与预期的一样。
但我可能需要扩展微服务并运行多个实例。在这种情况下，我将有多个消费者对同一主题。但是在这里，错误2429 : MQRC_SUBSCRIPTION_IN_USE失败了。我不能运行一个以上的消费者的主题订阅。注意:一条消息应该只发送给其中一位消费者。
有什么想法吗？
版本: 7.5我使用C客户机API连接到MQ。
浏览 2提问于2017-04-21得票数 2
回答已采纳
3回答
如何将消息从Amazon SQS传递到服务的所有运行实例
amazon-web-services、spring-boot、java-8、amazon-sqs
我有两个服务，一个是生产者(服务A)，另一个是消费者(服务B)。因此，服务A将生成一条消息，该消息将发布到Amazon SQS服务，然后在服务B订阅队列时将其交付给服务B。因此，在我拥有服务B的单个实例之前，它工作得很好。
但是，当我启动服务B的另一个实例时，现在有两个服务B的实例，这两个实例都订阅到相同的队列，因为它是相同的服务，我观察到来自SQS的消息现在以循环方式传递。这样在给定时间，只有一个服务B的实例接收由服务A发布的消息。我希望在将消息发布到此队列时，服务B的所有实例都应该接收该消息。
我们该怎么做呢？我已经开发了这些服务作为Springboot应用程序，以及Spring云依赖项。
浏览 0提问于2021-07-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
