标签: python-pulsar

如Pulsar Schema 注册表文档中的示例所示

Producer<User> producer = client.newProducer(JSONSchema.of(User.class))\n    .topic(topic)\n    .create();\nUser user = new User(\xe2\x80\x9cTom\xe2\x80\x9d, 28);\nproducer.send(User);\n

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

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

processor = PulsarClient.builder()\n            .serviceUrl("pulsar://pulsarhost:6650")\n            .build()\n            .newConsumer(JSONSchema.of(User.class))\n            .topic("sometopic")\n            .subscriptionName("somesubscription")\n            .subscribe();\n

Python：\n 导入脉冲星

client = pulsar.Client(\'pulsar://pulsarhost:6650\')\n\nproducer = client.create_producer(\'sometopic\')\nclient.close()\n