KafkaConsumer polls forever when the single broker is unreachable in case of manual partition assignments

wbarnha / kafka-python-ng

Fork for Python client for Apache Kafka

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

Apache License 2.0

67 stars 8 forks source link

KafkaConsumer polls forever when the single broker is unreachable in case of manual partition assignments #121

Open wbarnha opened 6 months ago

wbarnha commented 6 months ago

Different from the Java client KafkaConsumer blocks in ensureCoordinatorReady when the single broker is unreachable for manual partition assignments. In Java client the KafkaConsumer does not try to ensureCoordinatorReady in case of manual partition assignment.