Skip to content

Future hangs indefinetly when removed from the dict it is returned with. #1242

Open
@mkstickx

Description

@mkstickx

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

logs.txt

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugReporting an unexpected or problematic behavior of the codebase

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions