Regression in latest version of aiokafka

[patkivikram]

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

# Add a short Python script or Docker configuration that can reproduce the issue.

[alexmorley]

@patkivikram why did you close this? We've also ran into this (using faust-streaming) so interested to know what happened in your case?

[patkivikram]

Our app was able to recover after that. Is your app not able to reset?