from kafka.structs import ConsumerRecord  # noqa
from kafka.structs import TopicPartition