def start(self):
    while True:
        messages_by_partition = self.inbound_consumer.poll(timeout_ms=KAFKA_INBOUND_TIMEOUT, max_records=KAFKA_INBOUND_MAX_RECORDS)
        self.handle_messages(messages_by_partition)
def start(self):
    while True:
        messages_by_partition = self.inbound_consumer.poll(timeout_ms=KAFKA_INBOUND_TIMEOUT, max_records=KAFKA_INBOUND_MAX_RECORDS)
        self.handle_messages(messages_by_partition)