Propagate future.exception in producer/kafka.py _wait_on_metadata

wbarnha / kafka-python-ng

Fork for Python client for Apache Kafka

https://wbarnha.github.io/kafka-python-ng/

Apache License 2.0

42 stars 4 forks source link

Propagate future.exception in producer/kafka.py _wait_on_metadata #157

Open wbarnha opened 3 months ago

wbarnha commented 3 months ago

Propagate any exceptions that happened during the future; otherwise _wait_on_metadata will time out even though the error is being continuously reflected in the metadata status fetched from the broker. Issue #2078

This change is