def resume(topic, partition)
      pause_for(topic, partition).resume!

      # During re-balancing we might have lost the paused partition. Check if partition is still in group before seek.
      seek_to_next(topic, partition) if @group.assigned_to?(topic, partition)
    end
def resume(topic, partition)
      pause_for(topic, partition).resume!

      # During re-balancing we might have lost the paused partition. Check if partition is still in group before seek.
      seek_to_next(topic, partition) if @group.assigned_to?(topic, partition)
    end
Resume processing of a topic partition.

 @see #pause
 @param topic [String]
 @param partition [Integer]
 @return [nil]