Создание Key_Shared Consumer Apache Pulsar

Question

Я использую клиенты Apache Pulsar Python для подключения своих микросервисов. Я хочу создать Key_Shared Consumer, который делает следующее:

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.