aio-libs / aio-libs/aiokafka

Regression in latest version of aiokafka

Open
#718 3 comments 0 reactions 0 assignees View on GitHub
Dominant language
Python
Stars
1.4k
Forks
269
Avg merge
1d 1h
Merged PRs (30d)
6

Description

**Describe the bug**
We are seeing this issue again with version 0.7.0
https://github.com/aio-libs/aiokafka/issues/261

Our consumer just stops after logging
```aiokafka.consumer.fetcher Fetch offset 2370539 is out of range for partition TopicPartition(topic='xxx-fxxxxx_hopping_table-changelog', partition=1), resetting offset```

**Expected behaviour**
This should not stop the consumer from running
**Environment (please complete the following information):**
- aiokafka version 0.7.0(`python -c "import aiokafka; print(aiokafka.__version__)"`):
- kafka-python 2.0.2 (`python -c "import kafka; print(kafka.__version__)"`):
- Kafka Broker version 2.4.1 (`kafka-topics.sh --version`):
- Other information (Confluent Cloud version, etc.):

**Reproducible example**
```python
# Add a short Python script or Docker configuration that can reproduce the issue.
```

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.