def commit_current_message(self, topic_partition):
    LOGGER.info('Committing')
    self.inbound_consumer.commit()
    new_offset = self.inbound_consumer.committed(topic_partition)
    LOGGER.info('Committed. New Kafka offset: %s', new_offset)
def commit_current_message(self, topic_partition):
    LOGGER.info('Committing')
    self.inbound_consumer.commit()
    new_offset = self.inbound_consumer.committed(topic_partition)
    LOGGER.info('Committed. New Kafka offset: %s', new_offset)