import kafka.protocol as kp
from kafka.client_async import KafkaClient


kc = KafkaClient(bootstrap_servers=['kafka01.stg.local:9092'])

# first call to kc.send() always fails
gcr1 = kc.send(1, kp.commit.GroupCoordinatorRequest[0]('valid_group_name'))

gcr1.is_done  # always True even though I never called poll()
gcr1.failed()  # always True
gcr1.value  # `None`... the docs say this shold return a Response Struct or error?


# try it a second time:
gcr1 = kc.send(1, kp.commit.GroupCoordinatorRequest[0]('valid_group_name'))
gcr1.is_done  # always False until I call poll()

# will block until it gets a response... generally returns almost immediately
kc.poll(future=gcr1)

gcr1.value # always returns a Response struct