我是Apache Pulsar(也是MQ系统)的新手。现在,我有一个关于Pulsar Reader的问题。 问题描述:我启动一个Pulsar实例,然后启动一个使用者,听一个话题A。然后我启动一个生产者,向主题A发送100条消息,消费者使用了100条消息,消费者订阅中Backlog的值是0,该主题上只有一个订阅,并且是唯一的。 之后,我启动一个Reader,将Reader的主题设置为A,Reader可以从主题A中获取信息。 我在Pulsar文档中发现了这一点:https://pulsar.apache.org/doc…

2020年11月30日 0条评论 60点热度 阅读全文

我正在尝试为Pulsar建立一个Zookeeper集群。我正在按照here的说明进行操作,但是我一直失败。 在我的设置中,我有两个节点,它们应该是集群的一部分。由于我需要将bookie部署到相同的节点,因此我执行了 $ PULSAR_EXTRA_OPTS="-Dstats_server_port=8001" bin/pulsar-daemon start zookeeper 启动动物园管理员。之后,我尝试使用以下命令初始化集群: bin/pulsar initialize-cluster-metadata \ --…

2020年7月27日 0条评论 55点热度 阅读全文

我有一个围绕经纪人设计的系统,这样我的生产者使用Java,而消费者使用Go。 我正在使用apache-pulsar作为我的经纪人 Java-生产者 将MessageJava类转换为字节数组,然后再将其发送给pulsar :MessageJava类的对象调用同一类中定义的getBytes()方法将其转换为byte [],然后将该数组发送给apache-pulsar class MessageJava { String id; int entityId; Date timestamp; public byte[] ge…

2020年3月23日 0条评论 50点热度 阅读全文

我正在尝试将Apache Pulsar设置为log4j2的附加程序。没有太多文档,但是我设法在这里找到一些示例。我已经建立了一个玩具示例,其中生产者记录一条消息,而消费者在Pulsar服务器上订阅了相同的主题并收听消息。消费者收到了一些东西,但没有收到我所期望的消息: Message sent: Test message Message received: 18:05:27.510 [pulsar-client-io-5-1] INFO org.apache.pulsar.client.impl.ConsumerI…

2019年8月22日 0条评论 50点热度 阅读全文

我正在尝试订阅一个Apache Pulsar主题,我知道的某些租户,名称空间和主题都存在,因为其他使用者也可以订阅这个完全相同的主题。我已经仔细检查了我的URL和端口是否正确,以及我使用的是正确的信任证书。但是,我收到了Error Checking/Getting Partition Metadata while Subscribing异常,它无法连接。我正在尝试通过TLS与SSL连接。 我的Python代码如下所示,但是正如我在下面提到的,我在Java和Go中使用了相同的方法,并且在每种语言中我都得到了相同的结果…

2019年4月28日 0条评论 42点热度 阅读全文

我一直在研究Apache Pulsar的功能,对此我感到非常高兴。但是,我刚刚进入身份验证/授权,并且在Java管理客户端中遇到了一个奇怪的错误。 当我尝试使用以下方式授予角色名称空间权限时,虽然我能够执行各种操作,例如创建/删除租户,创建/删除名称空间,创建/删除分区主题,向管理员添加管理员角色等。 org.apache.pulsar.client.admin.Namespaces.grantPermissionOnNamespace() 我收到此错误: org.apache.pulsar.client.admi…

2019年4月15日 0条评论 37点热度 阅读全文