aiokafka
aiokafka copied to clipboard
Replace `assert`'s in Consumer methods with proper validation
Currently Consumer does something like:
assert all(map(lambda k: isinstance(k, TopicPartition), partitions))
- Replace this with a proper value check, raise sensible errors like TypeError or ValueError.
- Add respective simple validation tests