我认为一个简单的例子可以更好地描述我的问题。 例如，假设有一个名为"A“的主题，我生成了100条消息(message1...message100)。我已经使用类型为exclusive的订阅"A_1“消费并确认了消息50。由于某些原因，我的应用程序关闭了，因此在重新启动应用程序时，我需要再次读取消息1。这是否可以做到呢？我在想，创建一个新的订阅( "A_2“)并重新开始阅读消息</
浏览 50提问于2021-01-27得票数 2
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
1回答
我是Apache Pulsar的新手，但我正在尝试使用Pulsar-Functions来处理某个主题的现有消息。这些函数似乎仅用于流式传输，因此只有在新消息到达输入主题时才会触发它们。
浏览 12提问于2021-08-06得票数 0
1回答
我在Pulsar中有一个持续的话题，它有200条信息。前100条消息被确认，但其余的消息不被确认。我使用WebSockets连接到Pulsar主题来读取它们。这里是我的问题：，当我创建一个新的阅读器时，它似乎没有获取未被确认的100条消息。它将只获取在使读取器生成后排队的新消息。
如何使用读取器检索旧的未确认消息？当我使用“消费
浏览 1提问于2019-11-16得票数 2
我正在尝试使用Apache Pulsar编写一个多租户(多名称空间)系统。我似乎无法实现的是使用单个客户端/连接发布到这些命名空间中的多个命名空间和主题。消费者方面也是如此。从本质上讲，我希望使用单个应用程序实例能够发布到多个名称空间和主题，而使用一个消费者应用程序能够在消费时做到这一点。我只是想知道这是否可能。我不想为M个命名空间和每个命名空间的N个主题维护M*N个连接。我看到pulsar中支持正则表达式
浏览 4提问于2020-01-29得票数 4
我在一个apache pulsar集群上工作，它工作得很好，但由于某种原因，当我尝试发送消息时，我开始收到以下消息：
ERROR [id: 0xc5de4911, L:/127.0.0.1:55672persistent://global/mycluster-cluster1/ns1/topic-partition-0] [null] Error connecting to broker: org.apache.pulsar.c
浏览 19提问于2019-07-22得票数 0
回答已采纳
Apache有一个TTL特性，如官方文档的主题所示。但是，我无法确定在配置中设置了多久一次这样的检查。使用具有自定义命名空间的标准bin/pulsar standalone命令，配置为5秒bin/pulsar-admin namespaces set-message-ttl public/ttl-test--messageTTL 5的ttl。我可以看到，消息只有在设置间隔后才过期，下面的日志消息<
浏览 0提问于2019-03-20得票数 1
回答已采纳
applog-json无法创建生产者:名为'pulsar-log4j2-appender-applog-json‘的Producer已连接到主题2021-05-14 15:34:23,550主错误无法启动pulsar管理器pulsar manager pulsar-LOG4J2-appender applog-json已连接到位于org.apache.pulsar.client的主题。我使用的</e
浏览 3提问于2021-05-15得票数 1
是否可以使用Flink SQL client CLI与表交互，其中哪个表是在集群中运行的Scala/Java程序中创建的？
浏览 14提问于2019-05-09得票数 0
回答已采纳
1回答
我正在尝试将Apache设置为log4j2的一个附录。这里没有太多的文档，但是我在这里找到了一些例子。我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。消费者收到了一些东西，但没有收到我所期望的信息：Message received: 18:05:27.510 [pulsar-client-io-;
impor
浏览 5提问于2020-06-24得票数 3
回答已采纳
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：importconsumer.acknowledge(message); client.close();主题的客户端生产者生成消息时，所有操作都很好:消息
浏览 2提问于2022-05-31得票数 2
Apache的API ()至少包括两种使用来自Pulsar主题/队列的消息的方法：
大多数
浏览 4提问于2019-12-17得票数 5
回答已采纳
我们有一个使用案例，我们的消息处理器处理消息，对来自少数主题的消息进行非常复杂的计算。这些计算未在配置的重新计价期限内完成。我们是否可以为需要消息保留更长时间的少数主题设置此设置，而不是全局增加所有主题的消息保留时间？按主题保留消息是可能的吗？
浏览 55提问于2020-12-10得票数 1
我在Docker容器中以standalone模式运行Apache pulsar。脉冲星容器不断耗尽/磁盘上的磁盘空间，必须终止。docker-compose文件如下所示 image: apachepulsar/pulsar command:bin/pulsar<
浏览 3提问于2020-06-18得票数 1
我是(也是MQ系统)的新手。现在，我有个关于Pulsar阅读器的问题。问题描述：在那之后，我启动了一个阅读器，设置读者的主题是A，读者可以从
浏览 2提问于2019-11-21得票数 0
在Apache Pulsar文档中，我们有： ? 假设我们有一个生产者，它只生成一个分区主题和两个独占订阅(独占订阅保证了主题中的排序)！每次订阅都会按顺序消费消息吗？
浏览 22提问于2021-08-30得票数 0
回答已采纳
如何使用Akka Streams持续使用Apache Pulsar中的消息并打印每条消息？
下面是我从库中找到的示例代码。如何打印消费的消息，而不是将消息发布到另一个主题？
浏览 7提问于2020-05-22得票数 0
脉冲星是否有可能为每个散列创建一个主题(或分区)，并在不再使用时删除主题(或分区)？在开始使用另一个主题(或分区)之前，使用者还应该能够完全使用一个主题(或分区)。
因此，目标是能够以不同的顺序消费和生成数据。4 [z y x w v
浏览 1提问于2018-01-04得票数 4
回答已采纳
我正在尝试使用Apache Pulsar进行端到端加密。到目前为止，我看到的示例看起来类似于http://pulsar.apache.org/docs/en/security-encryption/ 我在密钥轮换部分看到每4小时获取一次加密密钥(公钥/私钥)这似乎表明您只能使用单个密钥来加密您发送的消息。 我希望能够对不同的主题/租户使用不同的</
浏览 24提问于2020-07-15得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
