You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
At least with recent versions if the bitnami/kafka:2 Kafka broker container image, aborted transactions can give rise to a situation in which the log for a given Kafka topic looks as follows:
Describe the bug
At least with recent versions if the
bitnami/kafka:2
Kafka broker container image, aborted transactions can give rise to a situation in which the log for a given Kafka topic looks as follows:Here, the log consists of the transaction abort marker only. Therefore,
aiokafka/aiokafka/consumer/fetcher.py
Line 267 in dbd490f
aiokafka/aiokafka/consumer/fetcher.py
Line 223 in dbd490f
KeyError
when attempting to consume the aforementioned topic.Expected behaviour
Consumer should proceed without error.
Environment (please complete the following information):
python -c "import aiokafka; print(aiokafka.__version__)"
): 0.7.2python -c "import kafka; print(kafka.__version__)"
): 2.0.2kafka-topics.sh --version
): 2.8.0 (Commit:ebb1d6e21cc92130)Reproducible example
The text was updated successfully, but these errors were encountered: