问题标签 [apache-pulsar]

我配置了broker.conf并尝试创建一个启用了 tls 的客户端。从字面上看，我正确提供了证书路径。当我尝试运行客户端时，它显示以下错误。

这是我从 apache pulsar 文档中遵循的 broker.conf 身份验证配置。

似乎没有使用代理中的端口 6651 启动主机连接。我检查了只有端口 6650 对连接开放。它可以在不启用 TLS 的情况下正常工作。

提前感谢您的帮助。

谢谢你。

是否可以在没有 Axon Server Enterprise的情况下扩展 Axon Framework ？我有兴趣使用 Axon 创建原型 CQRS 应用程序，但最终的可部署系统必须免收许可费。如果 Axon Framework 不能使用免费软件扩展到六个节点，那么我可能应该寻找其他地方。

如果 Axon Framework 最终不是系统的好选择，您会推荐什么？围绕 Apache Pulsar 构建一些东西会是一个明智的选择吗？

如Pulsar Schema Registry Docs中的示例所示

您可以使用 Java 客户端为生产者和消费者注册模式。还提到其他语言的客户端不支持模式注册表。

现在是否可以从 Python API 生产者发送关于 Pulsar 主题的消息，该消息将由具有注册模式的消费者使用？例如

Python：导入脉冲星

我希望有一个函数聚合事件并在簿记员中维护状态，同时允许处理不同事件的其他函数利用该状态（通过键访问，或通过键来查找状态。

我无法通过上下文对象找到任何方法，有不同的方法吗？

我正在尝试使用 go 模块使用 pulsar go 客户端，但无法使用正确的版本导入。

创建了一个带有 pulsar 依赖项的 go.mod 文件，还添加了其他依赖项，之前我使用的是 dep，一切都很好。现在我搬到了模块，其他包都很好，除了 pulsar 依赖，我不确定我错过了什么。

需要 github.com/apache/pulsar/pulsar-client-go：版本“v2.4.1”无效：未知版本 pulsar-client-go/v2.4.1

我在 Pulsar 中有一个持久主题，其中包含 200 条消息。前 100 条消息得到确认，但其余消息未得到确认。我正在使用 WebSockets 连接到 Pulsar 主题以阅读它们。

这是我的问题： 当我创建一个新的阅读器时，它似乎没有获取 100 条未被确认的消息。它只会获取读取器后排队的新消息。

如何使用阅读器检索旧的未确认消息？当我使用Consumer时，此设置有效。

我正在通过 WebSockets 使用 Apache Pulsar。当我使用阅读器从主题中获取数据时，如果我确认消息，它们会从主题中删除吗？我为该主题的命名空间设置了保留期，如下所示：

当我第一次使用阅读器时，我的设置有效；随着数据进入主题，我能够阅读它。但是为什么无法使用阅读器再次访问这些消息。

网址是：

ws://someEndPoint:8080/ws/v2/reader/persistent/public/default/topicName?messageId=earliest&receiverQueueSize=100000

我是 Apache Pulsar 的新手（也是 MQ 系统的新手）。现在，我有一个关于 Pulsar Reader 的问题。

问题描述：
我启动一个 Pulsar 实例，然后启动一个消费者，监听一个主题 A。然后我启动一个生产者，向主题 A 发送 100 条消息，消费者消费了这 100 条消息，消费者订阅中的 Backlog 值为 0 .该主题只有一个订阅，并且是独家的。

之后，我启动了一个 Reader，设置 Reader 的主题为 A，Reader 可以从主题 A 获取消息。

我在 Pulsar 文档上找到了这个： https ://pulsar.apache.org/docs/en/cookbooks-retention-expiry/

Pulsar 代理负责处理通过 Pulsar 传递的消息，包括消息的持久存储。默认情况下，经纪人：

立即删除每个订阅上已确认的所有消息，
并将所有未确认的消息永久存储在积压中。

这 100 条消息应该已经被删除了。那么为什么 Pulsar Reader 仍然可以从主题 A 中获取消息呢？

我的代码：

消费者：

生产商：

读者：

我一直在尝试进行一些搜索（Google、Slack、Stack），但还没有找到答案。我们有一些使用Spring Cloud Streams编写的应用程序，并且有兴趣将后端从 Kafka 交换到 Pulsar。Spring 目前没有对 Kafka 的任何原生支持，但是 pulsar 似乎提供了使用 Kafka API 直接与 pulsar 通信的能力（https://pulsar.apache.org/docs/en/adaptors-kafka）。

我想知道是否有人已经尝试Kafka-clients在 Spring 云消息传递的上下文中使用这个替代库来替代库。

当然，另一种有效的方法是重新编写代码——但我想求助于社区，看看是否有人已经走上了这条路。

谢谢

我用 Spring boot 编写了一个简单的 Apache Pulsar 客户端 - 一个初始化为 bean 的 pulsar-producer 将在其余控制器中用于将传入的 api 消息发布到 Pulsar，以及一个消费消息的消费者，在控制台中打印一些值并确认。

到目前为止，该应用程序非常简单，但是在加载此 spring-boot 应用程序的那一刻，我看到了内存峰值，有时会出现 OOM。将 Pulsar 客户端与 Spring-boot 一起使用时，是否需要使用任何特定配置？

该代码主要是在 Pulsar 文档中找到的代码。