问题标签 [apache-pulsar]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-pulsar - 通过 Pulsar 消费者批量读取消息
我正在使用节点 pulsar 客户端来使用来自 Pulsar 主题的消息。消费者使用shared订阅模式订阅主题。目前，每次调用receive都会从主题中获取一条消息。有没有办法批量接收消息？
python - 创建 Key_Shared Consumer Apache Pulsar
我使用 Apache Pulsar Python 客户端连接我的微服务。我想创建 Key_Shared Consumer 这样做：
但我收到以下错误：
KeyShared 是否已在 Python 客户端中实现？如果是，我该如何使用它？
java - Apache Pulsar：订阅时检查/获取分区元数据时出错
我正在尝试订阅一个 Apache Pulsar 主题，并且我确定租户、命名空间和主题都存在，因为其他消费者能够订阅这个完全相同的主题。我已经仔细检查了我的 URL 和端口是否正确，并且我使用了正确的信任证书。但是，我得到了异常Error Checking/Getting Partition Metadata while Subscribing，它不会连接。我正在尝试通过 TLS 连接 SSL。
我的 Python 代码看起来像这样，但正如我在下面提到的，我在 Java 和 Go 中使用了相同的方法，并且在每种语言中都得到了相同的结果：
我得到的例外情况详述如下：
我在使用 Java 和 Go 时遇到了同样的异常，所以它不是特定于 Python 的。
问题是什么？
apache-pulsar - 在 Windows Docker 中安装 Apache Pulsar
您能帮我如何使用 Windows docker 安装本地独立 pulsar 集群吗？我遵循了以下选项。但我无法访问 pulsar UI
8080 端口已经分配给其他进程。所以这里我使用的是 8081 端口。
选项1：
docker run -it -p 6650:6650 -p 8081:8081 --mount source=pulsardata,target=/pulsar/data --mount source=pulsarconf,target=/pulsar/conf apachepulsar/pulsar:2.5.2 bin/pulsar独立的
选项 2： docker run -it -p 6650:6650 -p 8081:8081 -v "$PWD/data:/pulsar/data".ToLower() apachepulsar/pulsar:2.5.2 bin/pulsar 独立
使用上述两个选项，我无法看到 INFO - [main:WebService] - Web Service 开始于http://127.0.0.1:8081.Also我无法访问系统中的以下 url .
脉冲星：//本地主机：6650
谢谢
logging - 如何在独立模式下为 Apache Pulsar 配置日志记录到文件？
我想将 Apache Pulsar 配置为在独立模式下将输出记录到文件中。
我在systemd服务中以独立模式运行 Pulsar，使用如下 exec 命令：
现在 Pulsar 日志配置记录在这里，并指定您可以使用配置属性，例如pulsar.root.logger通过 Log4J 配置日志记录。
但是不清楚的是您在哪里定义这些与日志相关的属性？它们放在哪个配置文件中？
还是应该log4j2.yaml直接修改？这不在文档中。例如更改pulsar.routing.appender.default为RollingFile似乎没有效果。
描述在独立模式下启用日志记录到文件的完整步骤将非常有帮助。
apache-pulsar - Apache Pulsar 连接被拒绝
在我的 Pulsar 消费者/生产者中，当尝试连接到 Pulsar 时，我收到以下错误消息：
java.util.concurrent.CompletionException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt( ..) 失败：连接被拒绝：pulsar-ms-tls.mydomain.com/10.16.60.179:6652
可能是什么问题？
diskspace - 容器中的 Apache Pulsar 磁盘使用情况
我在 Docker 容器中以standalone模式运行 Apache pulsar。
我正在将日志文件行发布到 pulsar 主题中。总日志大小约为 60G。
pulsar 容器不断耗尽磁盘上的磁盘空间，/不得不终止。
这是默认配置。docker-compose 文件如下所示
有没有办法限制脉冲星磁盘的使用，使其不会耗尽所有空间？
log4j2 - 如何将 Apache Pulsar 设置为 Log4j2 的附加程序？
我的任务是设置一个日志系统，该系统使用 Apache Pulsar 作为 Log4j2 的附加程序。我真的不知道如何设置它，似乎没有任何文档/示例可供参考。有谁知道如何去做？
python - python pulsar concumer 收到消息时被阻塞
我的应用程序中有两个 python 脚本 producer.py 和 consumer.py。
producer.py 生成两个主题，consumer.py 订阅两个主题（主题名称每次运行都会更改）。刚开始启动 producer.py 时，消费者收不到任何东西，进程处于阻塞状态。先启动consumer.py，再启动producer.py，consumer可以接收到第一个topic的数据，但是还是不能接收到第二个topic。
docker-compose - 使用 docker-compose 运行 apache pulsar
我可以使用这个 docker 命令运行 Apache Pulsar：
我正在尝试将其转换为 docker-compose，并使用下面的 docker-compose.yml 文件。当我运行命令时：
我收到错误消息：
附加到 pulsar pulsar | 错误：无法找到或加载主类“脉冲星以代码 1 退出
我在这里做错了什么？提前致谢。