FakeAIOKafkaConsumer.getmany, which it also implements
Mostly via inspection of aiokafka, though also some manual testing. I've also validated this by using it in some integration tests for a codebase already in production.
Fixes #107.
Builds on #110 and #111, which it contains; suggest reviewing them first then only considering the other changes here.
Review by commit may be useful here to understand the flow of some of the refactors.
This adds missing parameters to:
FakeAIOKafkaConsumer.subscribe
FakeAIOKafkaConsumer.getone
FakeAIOKafkaConsumer.getmany
, which it also implementsMostly via inspection of
aiokafka
, though also some manual testing. I've also validated this by using it in some integration tests for a codebase already in production.Fixes #107.
Builds on #110 and #111, which it contains; suggest reviewing them first then only considering the other changes here.
Review by commit may be useful here to understand the flow of some of the refactors.