[QUESTION] How to avoid missing messages between calls to AIOKafkaConsumer.subscribe
Open
question
- Dominant language
- Python
- Stars
- 1.4k
- Forks
- 269
- Avg merge
- 1d 1h
- Merged PRs (30d)
- 6
Description
If we're subscribed to channels "a" and "b" and we want to drop "a" and keep "b", the [docs](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.AIOKafkaConsumer.subscribe) for `AIOKafkaConsumer.subscribe` say "Topic subscriptions are not incremental: this list will replace the current assignment (if there is one)" so we would just call `subscribe` to subscribe to "b" only. But is there the possibility that we'll miss a message to "b" in between being subscribed to "a" and "b" and being subscribed to "b"? Is there a way to avoid this?
Contributor guide
Assessment
This issue has not been assessed yet.