问题标签 [python-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.
python - 创建 Key_Shared Consumer Apache Pulsar
我使用 Apache Pulsar Python 客户端连接我的微服务。我想创建 Key_Shared Consumer 这样做：
但我收到以下错误：
KeyShared 是否已在 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
谢谢
python - Pulsar GoClient 等效于 unacked_messages_timeout_ms (py-client)
在 Pulsar Python Client 中，有一个订阅者选项unacked_messages_timeout_ms来设置未确认消息将被重新传递的时间间隔。
Pulsar Go Client 中的等价物是什么？
Python
戈朗
我在这里找不到任何东西：https ://pkg.go.dev/github.com/apache/pulsar-client-go/pulsar#ConsumerOptions
如果不存在，如何配置重新发送间隔以及默认值是多少？
同样的问题也在 Github 问题中提出：https ://github.com/apache/pulsar-client-go/issues/608
python - 如何告诉python使用者等待客户端启动
我在 docker 容器中有一个基本问题，当我尝试开始创建和启动两个图像时，第二个图像（python 和一些脚本）依赖于第一个图像。
这会导致第二个图像出错并停止。如何采用我的 python 脚本在客户端使用，等待客户端启动？
我认为这个问题不一定是 Apache Pulsar 问题，但这里有一些文档供感兴趣的人使用
客户端上的消费者
java - 在 Apache Pulsar 中重放/重置消息
是否可以重播旧消息（在保留期内）？没有关于它的文档。我想根据时间戳或时间段来执行此操作。
对正确方向的提示将不胜感激。
python - 如何在 Python Apache pulsar pulsar-client 包中使用 protobuf 模式消息？
有没有办法通过使用 python 的 pulsar-client 包使用 Protobuf 模式将消息发布到 Apache Pulsar 主题？
根据文档，它仅支持 Avro、String、Json 和字节。有什么解决方法吗？ https://pulsar.apache.org/docs/ko/2.8.1/client-libraries-python/
apache-pulsar - 消费者被拒绝，因为不兼容的模式异常
我只是在这里做一些测试。我为一个主题设置了下面的架构：
我也将其设置is-allow-auto-update-schema为 false 和schema-validation-enforcetrue。然后我运行下面的代码：
我得到了一个，IncompatibleSchemaException但我不明白为什么，因为两个模式都表明消息应该只是一个字符串。
is-allow-auto-update-schema然后我检查了设置to时会发生什么，true并删除了主题的架构，然后自动上传了下一个架构：
事实证明，该schema字段现在包含某些内容。文档说：
对于原始类型，Pulsar 不会在 SchemaInfo 中存储任何模式数据。SchemaInfo 中的类型用于确定如何对数据进行序列化和反序列化。
我想我错过了一些东西：有人可以给我一个线索吗？谢谢！
python - 例外：Pulsar 错误：IncompatibleSchema
我是 Pulsar 的新手，我只是在探索一个新项目的功能。我正在尝试一个非常基本的示例来从基于模式的生产者发送数据。提供一些背景知识，我的想法是将数据从 apache-pulsar 发送到 Clickhouse 数据库。我已经完成了接收器连接器的设置，并使用以下命令进行了验证
bin/pulsar-admin sinks status --tenant public --namespace default --name jdbc-clickhouse-sink
bin/pulsar-admin sinks list --tenant public --namespace default 输出：[“jdbc-clickhouse-sink”]
所以我在 Clickhouse DB 中创建了一个表。我希望将数据发送到应保存在数据库中的主题。在这样做时，我想保持模式一致，所以我想设置一个模式。下面的示例代码
当我运行上面的代码时，我收到以下错误
有人可以帮助我在这里缺少什么