aio-libs / aio-libs/aiokafka

AIOKafkaConsumer recovery from whole-cluster-dead

未關閉
#703 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Python
星號
1.4k
分支
269
平均合併
1 天 1 小時
30 天內合併 PR
6

描述

Hey,
I ran into the following bug (or unexpected behavior) and would be glad to get your help with that, or any idea to what I'm doing wrong.
This bug is reproducing easily on my environment.

Thanks!

**Describe the bug**
1. Cluster of 3 brokers is up and running.
2. I run AIOKafkaConsumer with bootstrap_servers list which contains all 3 brokers.
3. I produce a message and it is consumed successfully by my AIOKafkaConsumer.
3. I kill all 3 brokers (as part of a test).
4. AIOKafkaConsumer repeatedly prints "NodeNotReadyError" about all 3 brokers (which is fine)
5. I start all 3 brokers
6. AIOKafkaConsumer stops printing "NodeNotReadyError" (which also looks fine)
7. I produce a message and AIOKafkaConsumer does not consume it, neither printing any error.

**Expected behaviour**
Step 7 should successfully consume the message

**Environment:**
- aiokafka version: 0.7.0
- kafka-python version: 1.3.5
- Kafka Broker version: 2.13-2.7.0

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。