创建Key_Shared消费者Apache Pulsar

Question

我使用Apache Pulsar Python客户端来连接我的微服务。我想创建Key_Shared消费者，如下所示：

import pulsar,_pulsar                

client = pulsar.Client('pulsar://localhost:6650')
consumer = client.subscribe('my-topic', 'consume-id',
             consumer_type=_pulsar.ConsumerType.KeyShared)

但我得到了以下错误：

AttributeError: type object 'ConsumerType' has no attribute 'KeyShared'

KeyShared已经在Python客户端实现了吗？如果是，我如何使用它？

Answer 1

它是在2.4.2中为Python客户端发布的。