Open
Description
Description
When i remove futures returned by methods of the AdminClient from the dict they are originally contained in, any calls to the result and exception method hang indefinitely.
How to reproduce
from confluent_kafka.admin import AdminClient, ConfigResource
client = AdminClient({"bootstrap.servers": "localhost"})
resource = ConfigResource("topic", "dev.test")
req_descriptions = client.describe_configs([resource])
value_list = req_descriptions[resource]
# Uncommenting the following line will cause future to hang indefinitely
# key, value_pop = req_descriptions.popitem()
print(value_list.result())
Checklist
Please provide the following information:
- confluent-kafka-python version ('1.7.0', 17235968) librdkafka version ('1.7.0', 17236223 )
- Apache Kafka broker version: Docker Container: wurstmeister/kafka 2.12-2.0.1
- Client configuration: {"bootstrap.servers": "localhost"}
- Operating system: Ubuntu 20.4 Python 3.8.10
- Provide client logs (with
'debug': '..'
as necessary) - Provide broker log excerpts
- Critical issue