io.py: put KafkaPartition directly into Kafka consumer assignment to not store a reference around
1 related merge request: !57 make KafkaClassifierData seek offsets for timestamps associated with it's start and end attributes and read all data between them
1 job
5 minutes 45 seconds, queued for 47 seconds